diff --git a/sql/core/src/main/scala/org/apache/spark/status/api/v1/sql/SqlResource.scala b/sql/core/src/main/scala/org/apache/spark/status/api/v1/sql/SqlResource.scala index c7599f864dd97..4dd96e5ae252b 100644 --- a/sql/core/src/main/scala/org/apache/spark/status/api/v1/sql/SqlResource.scala +++ b/sql/core/src/main/scala/org/apache/spark/status/api/v1/sql/SqlResource.scala @@ -94,7 +94,11 @@ private[v1] class SqlResource extends BaseAppResource { val duration = exec.completionTime.getOrElse(new Date()).getTime - exec.submissionTime val planDetails = if (planDescription) exec.physicalPlanDescription else "" - val nodes = if (details) printableMetrics(graph.allNodes, exec.metricValues) else Seq.empty + val nodes = if (details) { + printableMetrics(graph.allNodes, Option(exec.metricValues).getOrElse(Map.empty)) + } else { + Seq.empty + } val edges = if (details) graph.edges else Seq.empty new ExecutionData(