Added case None

Author: LucaCanali

core/src/main/scala/org/apache/spark/SparkContext.scala

@@ -632,6 +632,7 @@ class SparkContext(config: SparkConf) extends Logging {
     _executorMetricsSource match {
       case Some(executorMetricsSource: ExecutorMetricsSource) =>
         executorMetricsSource.register(_env.metricsSystem)
+      case None => None
     }
     _executorAllocationManager.foreach { e =>
       _env.metricsSystem.registerSource(e.executorAllocationManagerSource)
@@ -2490,6 +2491,7 @@ class SparkContext(config: SparkConf) extends Logging {
     executorMetricsSource match {
       case Some(executorMetricsSource: ExecutorMetricsSource) =>
         executorMetricsSource.updateMetricsSnapshot(currentMetrics)
+      case None => None
     }
 
     val driverUpdates = new HashMap[(Int, Int), ExecutorMetrics]

core/src/main/scala/org/apache/spark/executor/Executor.scala

@@ -127,6 +127,7 @@ private[spark] class Executor(
     executorMetricsSource match {
       case Some(executorMetricsSource: ExecutorMetricsSource) =>
         executorMetricsSource.register(env.metricsSystem)
+      case None => None
     }
     env.metricsSystem.registerSource(env.blockManager.shuffleMetricsSource)
   }

core/src/main/scala/org/apache/spark/executor/ExecutorMetricsPoller.scala

@@ -84,6 +84,7 @@ private[spark] class ExecutorMetricsPoller(
     executorMetricsSource match {
       case Some(executorMetricsSource: ExecutorMetricsSource) =>
         executorMetricsSource.updateMetricsSnapshot(latestMetrics)
+      case None => None
     }
 
     def updatePeaks(metrics: AtomicLongArray): Unit = {