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 171b812 commit e484419Copy full SHA for e484419
sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SQLListener.scala
@@ -51,17 +51,14 @@ private[sql] class SQLListener(sqlContext: SQLContext) extends SparkListener wit
51
52
private val completedExecutions = mutable.ListBuffer[SQLExecutionUIData]()
53
54
- @VisibleForTesting
55
def executionIdToData: Map[Long, SQLExecutionUIData] = synchronized {
56
_executionIdToData.toMap
57
}
58
59
60
def jobIdToExecutionId: Map[Long, Long] = synchronized {
61
_jobIdToExecutionId.toMap
62
63
64
65
def stageIdToStageMetrics: Map[Long, SQLStageMetrics] = synchronized {
66
_stageIdToStageMetrics.toMap
67
0 commit comments