diff --git a/sdk/python/feast/infra/contrib/spark_kafka_processor.py b/sdk/python/feast/infra/contrib/spark_kafka_processor.py
index 00363e4c78a..a76cb52e8aa 100644
--- 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
-