update the SAC-53 (#58)

[SAC-57] Reducing overhead to update entity for Spark Streaming query processing #57
hortonworks-spark · Jun 13, 2018 · 1f4018a · 1f4018a
1 parent fd600df
commit 1f4018a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...tor/src/main/scala/com/hortonworks/spark/atlas/SparkAtlasStreamingQueryEventTracker.scala b/...tor/src/main/scala/com/hortonworks/spark/atlas/SparkAtlasStreamingQueryEventTracker.scala
@@ -50,6 +50,7 @@ class SparkAtlasStreamingQueryEventTracker(
     logInfo(s"Track running Spark Streaming query in the Spark Atlas: $event")
     if(!streamQueryHashset.contains(event.progress.runId)) {
       streamingQueryTracker.pushEvent(event)
+      streamQueryHashset.add(event.progress.runId)
     }
   }