From 29c7d6000c59d9839c99a29b3cf00d879838b3e6 Mon Sep 17 00:00:00 2001 From: Jongyoul Lee Date: Mon, 12 Jan 2015 11:26:16 +0900 Subject: [PATCH] [SPARK-5198][Mesos] Change executorId more unique on mesos fine-grained mode - Change executorId from slaveId to taskId.getValue --- .../spark/scheduler/cluster/mesos/MesosSchedulerBackend.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosSchedulerBackend.scala b/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosSchedulerBackend.scala index 10e6886c16a4f..8e1e392242258 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosSchedulerBackend.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosSchedulerBackend.scala @@ -293,7 +293,7 @@ private[spark] class MesosSchedulerBackend( MesosTaskInfo.newBuilder() .setTaskId(taskId) .setSlaveId(SlaveID.newBuilder().setValue(slaveId).build()) - .setExecutor(createExecutorInfo(slaveId)) + .setExecutor(createExecutorInfo(taskId.getValue)) .setName(task.name) .addResources(cpuResource) .setData(ByteString.copyFrom(task.serializedTask))