fix: Remove unnecessary shutdown call in SparkKafkaProcessor

ExpediaGroup · Jan 17, 2025 · 141f218 · 141f218
1 parent 0c2e97c
commit 141f218
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/sdk/python/feast/infra/contrib/spark_kafka_processor.py b/sdk/python/feast/infra/contrib/spark_kafka_processor.py
@@ -313,8 +313,6 @@ def batch_write_pandas_df(iterator, spark_serialized_artifacts, join_keys):
                     lambda x: None,
                 )
 
-                online_store.shutdown()
-
             yield pd.DataFrame([pd.Series(range(1, 2))])  # dummy result
 
         def batch_write(