commit eee934750982a37a1296ed416e60fa9151bb5f6a
author Yaniv Rodenski <yaniv@shinto.io> Tue Apr 02 11:58:42 2019 +1100
committer Yaniv Rodenski <yaniv@shinto.io> Tue Apr 02 11:58:42 2019 +1100
tree 21ab1cc150ce523996901f32ff2633c04192a629
parent 2b217052c3263fd703fef3bd9f7261084d3fb43e

fixed build

frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/PySparkRunnerProvider.scala

diff --git a/frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/PySparkRunnerProvider.scala b/frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/PySparkRunnerProvider.scala
index 0309399..9be57a4 100644
--- a/frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/PySparkRunnerProvider.scala
+++ b/frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/PySparkRunnerProvider.scala
@@ -42,6 +42,8 @@
     Array[String]()
 
   override def getHasExecutor: Boolean = true
+
+  override def getActionExecutable(jobId: String, actionData: ActionData): String = ???
 }
 
 object PySparkRunnerProvider {

frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/SparkScalaRunnerProvider.scala

diff --git a/frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/SparkScalaRunnerProvider.scala b/frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/SparkScalaRunnerProvider.scala
index 80afa32..4c57ef3 100644
--- a/frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/SparkScalaRunnerProvider.scala
+++ b/frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/SparkScalaRunnerProvider.scala
@@ -61,6 +61,7 @@
 
   override def getHasExecutor: Boolean = true
 
+  override def getActionExecutable(jobId: String, actionData: ActionData): String = ???
 }
 
 object SparkScalaRunnerProvider {

frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/SparkSubmitScalaRunnerProvider.scala

diff --git a/frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/SparkSubmitScalaRunnerProvider.scala b/frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/SparkSubmitScalaRunnerProvider.scala
index 0f37f4d..51f8ad3 100644
--- a/frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/SparkSubmitScalaRunnerProvider.scala
+++ b/frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/SparkSubmitScalaRunnerProvider.scala
@@ -41,7 +41,7 @@
   override def getHasExecutor: Boolean = false
 
   override def getActionExecutable(jobId: String, actionData: ActionData): String = {
-    if (actionData.getHasArtifact) {
+//    if (actionData.getHasArtifact) {
 
       val util = new ArtifactUtil(List(actionData.repo).asJava, jobId)
       val result = conf.mode match {
@@ -49,10 +49,10 @@
         case "yarn" => util.getLocalArtifacts(actionData.getArtifact).toArray().map(x => x.asInstanceOf[File].getPath)
       }
       result(0)
-    } else {
-
-
-    }
+//    } else {
+//
+//
+//    }
   }
 }