Github user squito commented on a diff in the pull request:
https://github.com/apache/spark/pull/19698#discussion_r150655624
--- Diff: core/src/main/scala/org/apache/spark/status/AppStatusStore.scala
---
@@ -66,13 +66,8 @@ private[spark] class AppStatusStore(store: KVStore) {
filtered.asScala.map(_.info).toSeq
}
- def executorSummary(executorId: String): Option[v1.ExecutorSummary] = {
- try {
- Some(store.read(classOf[ExecutorSummaryWrapper], executorId).info)
- } catch {
- case _: NoSuchElementException =>
- None
- }
+ def executorSummary(executorId: String): v1.ExecutorSummary = {
+ store.read(classOf[ExecutorSummaryWrapper], executorId).info
--- End diff --
nit: indentation
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
