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 d19c232 commit a23f1f5Copy full SHA for a23f1f5
core/src/main/scala/org/apache/spark/status/AppStatusStore.scala
@@ -136,11 +136,7 @@ private[spark] class AppStatusStore(
136
store.read(classOf[StageDataWrapper], Array(stageId, stageAttemptId)).locality
137
}
138
139
- private def isInMemoryStore: Boolean = store match {
140
- case _: InMemoryStore => true
141
- case _: ElementTrackingStore => true // Live UI
142
- case _ => false
143
- }
+ private def isInMemoryStore: Boolean = store.isInstanceOf[InMemoryStore] || listener.isDefined
144
145
/**
146
* Calculates a summary of the task metrics for the given stage attempt, returning the
0 commit comments