We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f24bf52 commit 62398ecCopy full SHA for 62398ec
1 file changed
sql/core/src/test/scala/org/apache/spark/sql/execution/ui/SQLListenerSuite.scala
@@ -147,7 +147,8 @@ class SQLListenerSuite extends SparkFunSuite with SharedSQLContext with JsonTest
147
148
checkAnswer(listener.getExecutionMetrics(0), accumulatorUpdates.mapValues(_ * 2))
149
150
- // Non-existing driver accumulator updates should be filtered and no exception will be thrown.
+ // Driver accumulator updates don't belong to this execution should be filtered and no
151
+ // exception will be thrown.
152
listener.onOtherEvent(SparkListenerDriverAccumUpdates(0, Seq((999L, 2L))))
153
154
0 commit comments