Update spark_kafka_processor.py

ExpediaGroup · Jan 28, 2025 · 7c7d9d4 · 7c7d9d4
1 parent 89fee3b
commit 7c7d9d4
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/sdk/python/feast/infra/contrib/spark_kafka_processor.py b/sdk/python/feast/infra/contrib/spark_kafka_processor.py
@@ -497,4 +497,3 @@ def batch_write(row: DataFrame, batch_id: int):
 
         query.awaitTermination(timeout=self.query_timeout)
         return query
-