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 a42f418 commit bb7388bCopy full SHA for bb7388b
sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SQLAppStatusStore.scala
@@ -59,9 +59,6 @@ private[sql] class SQLAppStatusStore(
59
60
def executionMetrics(executionId: Long): Map[Long, String] = {
61
val exec = store.read(classOf[SQLExecutionUIData], executionId)
62
-
63
- // Need to try to read from the underlying store twice, in case the live execution data is
64
- // removed from the listener while this method is running.
65
Option(exec.metricValues)
66
.orElse(listener.map(_.executionMetrics(executionId)))
67
.getOrElse(Map())
0 commit comments