From 465893671c7514b1f38d4cbd568ceefa48737b1f Mon Sep 17 00:00:00 2001 From: Subhobrata Dey Date: Mon, 25 Apr 2016 22:11:17 -0400 Subject: [PATCH] [SPARK-14889][Spark Core] scala.MatchError: NONE (of class scala.Enumeration) when spark.scheduler.mode=NONE --- core/src/main/scala/org/apache/spark/scheduler/Pool.scala | 2 ++ .../scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala | 2 ++ 2 files changed, 4 insertions(+) diff --git a/core/src/main/scala/org/apache/spark/scheduler/Pool.scala b/core/src/main/scala/org/apache/spark/scheduler/Pool.scala index 4cd13e2feaeb1..a79e71ec7c9bf 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/Pool.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/Pool.scala @@ -55,6 +55,8 @@ private[spark] class Pool( new FairSchedulingAlgorithm() case SchedulingMode.FIFO => new FIFOSchedulingAlgorithm() + case _ => + throw new IllegalArgumentException(s"Unsupported spark.scheduler.mode: $schedulingMode") } } diff --git a/core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala b/core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala index c3159188d9f03..f31ec2af4ebd6 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala @@ -135,6 +135,8 @@ private[spark] class TaskSchedulerImpl( new FIFOSchedulableBuilder(rootPool) case SchedulingMode.FAIR => new FairSchedulableBuilder(rootPool, conf) + case _ => + throw new IllegalArgumentException(s"Unsupported spark.scheduler.mode: $schedulingMode") } } schedulableBuilder.buildPools()