Fix setRetries call from Jobclient.Builder to Job.Builder

WenboZhao · Apr 18, 2017 · 56fcd89 · 56fcd89
1 parent 3d40366
commit 56fcd89
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/scala/org/apache/spark/scheduler/CoarseCookSchedulerBackend.scala b/core/src/main/scala/org/apache/spark/scheduler/CoarseCookSchedulerBackend.scala
@@ -109,7 +109,6 @@ class CoarseCookSchedulerBackend(
     .setStatusUpdateInterval(10)
     .setBatchRequestSize(24)
     .setKerberosAuth()
-    .setRetries(1)
     .build()
 
   private[this] val jobListener = new CJobListener {
@@ -279,6 +278,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) {