From fa4206fc4c4cdd7495b523768d136b52f496a592 Mon Sep 17 00:00:00 2001 From: addyclement Date: Sun, 29 Jan 2023 17:18:13 +0200 Subject: [PATCH] remove duplicate code on line - 193 --- bexley_spark_stream_msk_es.py | 2 -- 1 file changed, 2 deletions(-) diff --git a/bexley_spark_stream_msk_es.py b/bexley_spark_stream_msk_es.py index 5511082..3bae341 100644 --- 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()