Github user efimpoberezkin commented on a diff in the pull request: https://github.com/apache/spark/pull/21063#discussion_r184342675 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ProgressReporter.scala --- @@ -111,7 +112,12 @@ trait ProgressReporter extends Logging { logDebug("Starting Trigger Calculation") lastTriggerStartTimestamp = currentTriggerStartTimestamp currentTriggerStartTimestamp = triggerClock.getTimeMillis() - currentStatus = currentStatus.copy(isTriggerActive = true) + // isTriggerActive field is kept false for ContinuousExecution + // since it is tied to MicroBatchExecution + this match { --- End diff -- Yep, an oversight on my part. Fixed it.
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org