From 56fcd890b6c1b91c8c796ef7ed3bafab5907ccf7 Mon Sep 17 00:00:00 2001 From: Wenbo Zhao Date: Tue, 18 Apr 2017 09:43:00 -0400 Subject: [PATCH] Fix setRetries call from Jobclient.Builder to Job.Builder --- .../org/apache/spark/scheduler/CoarseCookSchedulerBackend.scala | 2 +- 1 file changed, 1 insertion(+), 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 index 0d533743569af..07a321764ecd6 100644 --- 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) {