remove duplicate code on line - 193

amotolani · Jan 29, 2023 · fa4206f · fa4206f
1 parent 3efdded
commit fa4206f
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/bexley_spark_stream_msk_es.py b/bexley_spark_stream_msk_es.py
@@ -189,5 +189,3 @@ def foreach_batch(stream_df_04, epoch_id):
 stream_df_05 = stream_df_04.writeStream.foreachBatch(foreach_batch).queryName("bexley-stream").start()
 
 stream_df_05.awaitTermination()
-
-stream_df_05.awaitTermination()