Merge pull request #602 from drexin/wip-drexin-fix-executor-id

brndnmtthws · brndnmtthws · commit c9a23aec91af · 2015-12-11T13:14:27.000-08:00
Set executor id to job name instead of static value
diff --git a/src/main/scala/org/apache/mesos/chronos/scheduler/mesos/MesosTaskBuilder.scala b/src/main/scala/org/apache/mesos/chronos/scheduler/mesos/MesosTaskBuilder.scala
@@ -182,7 +182,7 @@ class MesosTaskBuilder @Inject()(val conf: SchedulerConfiguration) {
       command.setUser(job.runAsUser)
     }
     val executor = ExecutorInfo.newBuilder()
-      .setExecutorId(ExecutorID.newBuilder().setValue("shell-wrapper-executor"))
+      .setExecutorId(ExecutorID.newBuilder().setValue(job.name))
       .setCommand(command.build())
     if (job.container != null) {
       executor.setContainer(createContainerInfo(job))

Original file line number	Diff line number	Diff line change
`@@ -182,7 +182,7 @@ class MesosTaskBuilder @Inject()(val conf: SchedulerConfiguration) {`
`182`	`182`	`command.setUser(job.runAsUser)`
`183`	`183`	`}`
`184`	`184`	`val executor = ExecutorInfo.newBuilder()`
`185`		`- .setExecutorId(ExecutorID.newBuilder().setValue("shell-wrapper-executor"))`
	`185`	`+ .setExecutorId(ExecutorID.newBuilder().setValue(job.name))`
`186`	`186`	`.setCommand(command.build())`
`187`	`187`	`if (job.container != null) {`
`188`	`188`	`executor.setContainer(createContainerInfo(job))`