From 9ee7bf3e1ca16fbdbb289651f5ee2b41c460e8ed Mon Sep 17 00:00:00 2001 From: liorze Date: Tue, 26 Jul 2016 12:01:04 +0300 Subject: [PATCH] MESOS/KAFKA-242: Consistent task name for brokers --- src/scala/ly/stealth/mesos/kafka/Config.scala | 2 ++ src/scala/ly/stealth/mesos/kafka/Scheduler.scala | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/src/scala/ly/stealth/mesos/kafka/Config.scala b/src/scala/ly/stealth/mesos/kafka/Config.scala index fbde1b4..a7dfa3b 100644 --- a/src/scala/ly/stealth/mesos/kafka/Config.scala +++ b/src/scala/ly/stealth/mesos/kafka/Config.scala @@ -38,6 +38,8 @@ object Config { var frameworkRole: String = "*" var frameworkTimeout: Period = new Period("30d") + var taskName: String = "executor" + var jre: File = null var log: File = null var api: String = null diff --git a/src/scala/ly/stealth/mesos/kafka/Scheduler.scala b/src/scala/ly/stealth/mesos/kafka/Scheduler.scala index abfb5f8..c848db0 100644 --- a/src/scala/ly/stealth/mesos/kafka/Scheduler.scala +++ b/src/scala/ly/stealth/mesos/kafka/Scheduler.scala @@ -100,7 +100,7 @@ object Scheduler extends org.apache.mesos.Scheduler { } val taskBuilder: TaskInfo.Builder = TaskInfo.newBuilder - .setName(Config.frameworkName + "-" + broker.id) + .setName(Config.frameworkName + "-" + Config.taskName) .setTaskId(TaskID.newBuilder.setValue(Broker.nextTaskId(broker)).build) .setSlaveId(offer.getSlaveId) .setData(taskData)