From ef35e4892187db3f571d344a911a57f5b4bdb79f Mon Sep 17 00:00:00 2001 From: Meelap Shah Date: Thu, 30 Mar 2017 17:36:37 -0400 Subject: [PATCH] only record task launch with the offer used --- .../mesos/chronos/scheduler/mesos/MesosJobFramework.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/scala/org/apache/mesos/chronos/scheduler/mesos/MesosJobFramework.scala b/src/main/scala/org/apache/mesos/chronos/scheduler/mesos/MesosJobFramework.scala index b24cf5897..b5f8fd6c2 100644 --- a/src/main/scala/org/apache/mesos/chronos/scheduler/mesos/MesosJobFramework.scala +++ b/src/main/scala/org/apache/mesos/chronos/scheduler/mesos/MesosJobFramework.scala @@ -168,7 +168,7 @@ class MesosJobFramework @Inject()( List(offer.getId).asJava, mesosTasks.asJava )) - for (task <- tasks) { + for (task <- subTasks) { val name = task._2.name taskManager.addTask(name, task._3.getSlaveId.getValue, task._1) scheduler.handleLaunchedTask(task._2)