We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f4357d1 commit 6eb1396Copy full SHA for 6eb1396
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ProgressReporting.scala
@@ -214,9 +214,9 @@ trait ProgressReporting extends Logging {
214
val result = body
215
val endTime = triggerClock.getTimeMillis()
216
val timeTaken = math.max(endTime - startTime, 0)
217
- currentDurationsMs.put(
218
- triggerDetailKey,
219
- currentDurationsMs.getOrDefault(triggerDetailKey, 0) + timeTaken)
+
+ val previousTime = Option(currentDurationsMs.get(triggerDetailKey)).getOrElse(0L)
+ currentDurationsMs.put(triggerDetailKey, previousTime + timeTaken)
220
logDebug(s"$triggerDetailKey took $timeTaken ms")
221
result
222
}
0 commit comments