File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -50,10 +50,10 @@ class StreamingQueryListenerBus(sparkListenerBus: LiveListenerBus)
5050 * query, even it its a restart. So even if a query is restarted, this bus will identify them
5151 * separately and correctly account for the restart.
5252 *
53- * Note 2: This list needs to be maintained separately
54- * from the `StreamingQueryManager.activeQueries` because a terminated query is cleared from
55- * `StreamingQueryManager.activeQueries` as soon as it is stopped, but the this ListenerBus must
56- * clear a query only after the termination event of that query has been posted.
53+ * Note 2: This list needs to be maintained separately from the
54+ * `StreamingQueryManager.activeQueries` because a terminated query is cleared from
55+ * `StreamingQueryManager.activeQueries` as soon as it is stopped, but the this ListenerBus
56+ * must clear a query only after the termination event of that query has been posted.
5757 */
5858 private val activeQueryRunIds = new mutable.HashSet [UUID ]
5959
You can’t perform that action at this time.
0 commit comments