Fix setRetries call from Jobclient.Builder to Job.Builder

(cherry picked from commit 2a6f9d8) (cherry picked from commit 5436c08) (cherry picked from commit 32e4d65) (cherry picked from commit 1797dde) (cherry picked from commit 87c9a47)
curtishoward · Oct 8, 2018 · e31784d · e31784d
1 parent 79257df
commit e31784d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cook/src/main/scala/org/apache/spark/scheduler/cluster/cook/CoarseCookSchedulerBackend.scala b/cook/src/main/scala/org/apache/spark/scheduler/cluster/cook/CoarseCookSchedulerBackend.scala
@@ -110,7 +110,6 @@ class CoarseCookSchedulerBackend(
     .setStatusUpdateInterval(10)
     .setBatchRequestSize(24)
     .setKerberosAuth()
-    .setRetries(1)
     .build()
 
   private[this] val jobListener = new CJobListener {
@@ -280,6 +279,7 @@ class CoarseCookSchedulerBackend(
       .setMemory(executorMemory(sc).toDouble)
       .setCpus(numCores)
       .setPriority(priority)
+      .setRetries(1)
 
     val container = conf.get("spark.executor.cook.container", null)
     if(container != null) {