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 index c9655532c..3a54e0c95 100644 --- a/src/main/scala/org/apache/mesos/chronos/scheduler/mesos/MesosTaskBuilder.scala +++ b/src/main/scala/org/apache/mesos/chronos/scheduler/mesos/MesosTaskBuilder.scala @@ -138,6 +138,7 @@ class MesosTaskBuilder @Inject()(val conf: SchedulerConfiguration) { val (_, start, attempt, _) = TaskUtils.parseTaskId(taskIdStr) val baseEnv = Map( "mesos_task_id" -> taskIdStr, + "MESOS_TASK_ID" -> taskIdStr, "CHRONOS_JOB_OWNER" -> job.owner, "CHRONOS_JOB_NAME" -> job.name, "HOST" -> offer.getHostname, diff --git a/src/test/scala/org/apache/mesos/chronos/scheduler/mesos/MesosTaskBuilderSpec.scala b/src/test/scala/org/apache/mesos/chronos/scheduler/mesos/MesosTaskBuilderSpec.scala index a5cf8fb1f..623331e59 100644 --- a/src/test/scala/org/apache/mesos/chronos/scheduler/mesos/MesosTaskBuilderSpec.scala +++ b/src/test/scala/org/apache/mesos/chronos/scheduler/mesos/MesosTaskBuilderSpec.scala @@ -51,6 +51,7 @@ class MesosTaskBuilderSpec extends SpecificationWithJUnit with Mockito { val defaultEnv = Map( "mesos_task_id" -> taskId, + "MESOS_TASK_ID" -> taskId, "CHRONOS_JOB_OWNER" -> job.owner, "CHRONOS_JOB_NAME" -> job.name, "HOST" -> offer.getHostname,