Skip to content

Commit 5436c08

Browse files
WenboZhaoCurtis Howard
authored andcommitted
Fix setRetries call from Jobclient.Builder to Job.Builder
(cherry picked from commit 2a6f9d8)
1 parent 3457934 commit 5436c08

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

cook/src/main/scala/org/apache/spark/scheduler/cluster/cook/CoarseCookSchedulerBackend.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,6 @@ class CoarseCookSchedulerBackend(
110110
.setStatusUpdateInterval(10)
111111
.setBatchRequestSize(24)
112112
.setKerberosAuth()
113-
.setRetries(1)
114113
.build()
115114

116115
private[this] val jobListener = new CJobListener {
@@ -280,6 +279,7 @@ class CoarseCookSchedulerBackend(
280279
.setMemory(executorMemory(sc).toDouble)
281280
.setCpus(numCores)
282281
.setPriority(priority)
282+
.setRetries(1)
283283

284284
val container = conf.get("spark.executor.cook.container", null)
285285
if(container != null) {

0 commit comments

Comments
 (0)