removed uneeded chars
authorYaniv Rodenski <roadan@gmail.com>
Fri, 12 Oct 2018 11:02:39 +0000 (22:02 +1100)
committerYaniv Rodenski <roadan@gmail.com>
Fri, 12 Oct 2018 11:02:39 +0000 (22:02 +1100)
frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/SparkSetupProvider.scala
frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/SparkShellScalaRunnerProvider.scala

index e0a6f8d..96ab22f 100644 (file)
@@ -68,7 +68,7 @@ class SparkSetupProvider extends FrameworkSetupProvider {
 
   override def getEnvironmentVariables: util.Map[String, String] = conf.mode match {
     case "mesos" => Map[String, String](s"SPARK_HOME" -> s"spark-${conf.Webserver.sparkVersion}")
-    case "yarn" => Map[String, String]("SPARK_HOME" -> "spark")we e
+    case "yarn" => Map[String, String]("SPARK_HOME" -> "spark")
     case _ => Map[String, String]()
   }
 
index dd9428b..709ce0f 100644 (file)
@@ -14,7 +14,7 @@ class SparkShellScalaRunnerProvider extends RunnerSetupProvider {
     s"$$SPARK_HOME/bin/spark-shell ${actionData.src} --jars spark-runtime-${conf.version}.jar"
   }
 
-  override def getRunnerResources = ???
+  override def getRunnerResources: Array[String] = Array[String]()
 }
 
 object SparkShellScalaRunnerProvider {