Merge pull request #621 from solarkennedy/constraints_hint

gkleiman · gkleiman · commit 94b281a1d488 · 2016-01-28T15:16:18.000+01:00
Log a hint that constraints are not met for a task
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
@@ -153,7 +153,7 @@ class MesosJobFramework @Inject()(
                   case None =>
                     val foundResources = offerResources.toIterator.map(_._2.toString()).mkString(",")
                     log.warning(
-                      "Insufficient resources remaining for task '%s', will append to queue. (Needed: [%s], Found: [%s])"
+                      "Insufficient resources or constraints not met for task '%s', will append to queue. (Needed: [%s], Found: [%s])"
                         .stripMargin.format(taskId, neededResources, foundResources)
                     )
                     taskManager.enqueue(taskId, job.highPriority)

Original file line number	Diff line number	Diff line change
`@@ -153,7 +153,7 @@ class MesosJobFramework @Inject()(`
`153`	`153`	`case None =>`
`154`	`154`	`val foundResources = offerResources.toIterator.map(_._2.toString()).mkString(",")`
`155`	`155`	`log.warning(`
`156`		`- "Insufficient resources remaining for task '%s', will append to queue. (Needed: [%s], Found: [%s])"`
	`156`	`+ "Insufficient resources or constraints not met for task '%s', will append to queue. (Needed: [%s], Found: [%s])"`
`157`	`157`	`.stripMargin.format(taskId, neededResources, foundResources)`
`158`	`158`	`)`
`159`	`159`	`taskManager.enqueue(taskId, job.highPriority)`