You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by kikicarbonell <gi...@git.apache.org> on 2018/05/15 15:45:13 UTC
[GitHub] flink issue #3744: [FLINK-6336] Initial commit of mesos placement constraint...
Github user kikicarbonell commented on the issue:
https://github.com/apache/flink/pull/3744
I'm using Flink package version 1.4.0-1 and when I try to apply node host constrains setting environment variable: `FLINK_DISPATCHER_MESOS_HOSTATTRIBUTE = noderole:proc` the log file show an error to apply host constrains:
```
ve$1.applyOrElse(FSM.scala:617)
at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.aroundReceive(LaunchCoordinator.scala:48)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
at akka.actor.ActorCell.invoke(ActorCell.scala:495)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at com.netflix.fenzo.AssignableVirtualMachine.findFailedHardConstraints(AssignableVirtualMachine.java:784)
at com.netflix.fenzo.AssignableVirtualMachine.tryRequest(AssignableVirtualMachine.java:581)
at com.netflix.fenzo.TaskScheduler.evalAssignments(TaskScheduler.java:796)
at com.netflix.fenzo.TaskScheduler.access$1500(TaskScheduler.java:70)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:670)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:667)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2018-05-15 15:42:22,784 ERROR com.netflix.fenzo.TaskScheduler - Unexpected during concurrent task assignment eval - java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
java.util.concurrent.ExecutionException: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at com.netflix.fenzo.TaskScheduler.doSchedule(TaskScheduler.java:678)
at com.netflix.fenzo.TaskScheduler.scheduleOnce(TaskScheduler.java:600)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:173)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:144)
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at akka.actor.FSM$class.processEvent(FSM.scala:663)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.processEvent(LaunchCoordinator.scala:48)
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:657)
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:617)
at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.aroundReceive(LaunchCoordinator.scala:48)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
at akka.actor.ActorCell.invoke(ActorCell.scala:495)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at com.netflix.fenzo.AssignableVirtualMachine.findFailedHardConstraints(AssignableVirtualMachine.java:784)
at com.netflix.fenzo.AssignableVirtualMachine.tryRequest(AssignableVirtualMachine.java:581)
at com.netflix.fenzo.TaskScheduler.evalAssignments(TaskScheduler.java:796)
at com.netflix.fenzo.TaskScheduler.access$1500(TaskScheduler.java:70)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:670)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:667)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2018-05-15 15:42:22,785 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below)
2018-05-15 15:42:22,787 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.231 has 14478.0 MB, 3.6 cpus
2018-05-15 15:42:22,787 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.234 has 13166.0 MB, 3.1 cpus
2018-05-15 15:42:22,787 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.201 has 1902.0 MB, 2.8 cpus
2018-05-15 15:42:22,787 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.235 has 14478.0 MB, 3.6 cpus
2018-05-15 15:42:22,787 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.202 has 1326.0 MB, 3.2 cpus
2018-05-15 15:42:22,788 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.232 has 13966.0 MB, 3.6 cpus
2018-05-15 15:42:22,788 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.233 has 12910.0 MB, 2.9 cpus
2018-05-15 15:42:22,788 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.216 has 3598.0 MB, 3.5 cpus
2018-05-15 15:42:22,788 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.217 has 3374.0 MB, 2.6 cpus
2018-05-15 15:42:22,788 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.236 has 13966.0 MB, 3.3 cpus
2018-05-15 15:42:22,788 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.203 has 4654.0 MB, 3.3 cpus
2018-05-15 15:42:22,788 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.204 has 4142.0 MB, 1.9 cpus
2018-05-15 15:42:22,788 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.218 has 302.0 MB, 1.4 cpus
2018-05-15 15:42:22,788 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.219 has 4910.0 MB, 2.8 cpus
2018-05-15 15:42:22,790 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 3 task(s) are not yet launched.
2018-05-15 15:42:27,808 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 3 task(s) against 0 new offer(s) plus outstanding offers.
2018-05-15 15:42:27,811 ERROR com.netflix.fenzo.TaskScheduler - Unexpected during concurrent task assignment eval - java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
java.util.concurrent.ExecutionException: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at com.netflix.fenzo.TaskScheduler.doSchedule(TaskScheduler.java:678)
at com.netflix.fenzo.TaskScheduler.scheduleOnce(TaskScheduler.java:600)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:173)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:144)
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at akka.actor.FSM$class.processEvent(FSM.scala:663)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.processEvent(LaunchCoordinator.scala:48)
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:657)
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:617)
at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.aroundReceive(LaunchCoordinator.scala:48)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
at akka.actor.ActorCell.invoke(ActorCell.scala:495)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at com.netflix.fenzo.AssignableVirtualMachine.findFailedHardConstraints(AssignableVirtualMachine.java:784)
at com.netflix.fenzo.AssignableVirtualMachine.tryRequest(AssignableVirtualMachine.java:581)
at com.netflix.fenzo.TaskScheduler.evalAssignments(TaskScheduler.java:796)
at com.netflix.fenzo.TaskScheduler.access$1500(TaskScheduler.java:70)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:670)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:667)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2018-05-15 15:42:27,815 ERROR com.netflix.fenzo.TaskScheduler - Unexpected during concurrent task assignment eval - java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
java.util.concurrent.ExecutionException: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at com.netflix.fenzo.TaskScheduler.doSchedule(TaskScheduler.java:678)
at com.netflix.fenzo.TaskScheduler.scheduleOnce(TaskScheduler.java:600)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:173)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:144)
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at akka.actor.FSM$class.processEvent(FSM.scala:663)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.processEvent(LaunchCoordinator.scala:48)
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:657)
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:617)
at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.aroundReceive(LaunchCoordinator.scala:48)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
at akka.actor.ActorCell.invoke(ActorCell.scala:495)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at com.netflix.fenzo.AssignableVirtualMachine.findFailedHardConstraints(AssignableVirtualMachine.java:784)
at com.netflix.fenzo.AssignableVirtualMachine.tryRequest(AssignableVirtualMachine.java:581)
at com.netflix.fenzo.TaskScheduler.evalAssignments(TaskScheduler.java:796)
at com.netflix.fenzo.TaskScheduler.access$1500(TaskScheduler.java:70)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:670)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:667)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2018-05-15 15:42:27,816 ERROR com.netflix.fenzo.TaskScheduler - Unexpected during concurrent task assignment eval - java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
java.util.concurrent.ExecutionException: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at com.netflix.fenzo.TaskScheduler.doSchedule(TaskScheduler.java:678)
at com.netflix.fenzo.TaskScheduler.scheduleOnce(TaskScheduler.java:600)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:173)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:144)
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at akka.actor.FSM$class.processEvent(FSM.scala:663)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.processEvent(LaunchCoordinator.scala:48)
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:657)
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:617)
at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.aroundReceive(LaunchCoordinator.scala:48)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
at akka.actor.ActorCell.invoke(ActorCell.scala:495)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at com.netflix.fenzo.AssignableVirtualMachine.findFailedHardConstraints(AssignableVirtualMachine.java:784)
at com.netflix.fenzo.AssignableVirtualMachine.tryRequest(AssignableVirtualMachine.java:581)
at com.netflix.fenzo.TaskScheduler.evalAssignments(TaskScheduler.java:796)
at com.netflix.fenzo.TaskScheduler.access$1500(TaskScheduler.java:70)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:670)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:667)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2018-05-15 15:42:27,817 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below)
2018-05-15 15:42:27,817 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.231 has 14478.0 MB, 3.6 cpus
2018-05-15 15:42:27,817 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.234 has 13166.0 MB, 3.1 cpus
2018-05-15 15:42:27,818 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.201 has 1902.0 MB, 2.8 cpus
2018-05-15 15:42:27,818 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.235 has 14478.0 MB, 3.6 cpus
2018-05-15 15:42:27,818 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.202 has 1326.0 MB, 3.2 cpus
2018-05-15 15:42:27,818 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.232 has 13966.0 MB, 3.6 cpus
2018-05-15 15:42:27,818 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.233 has 12910.0 MB, 2.9 cpus
2018-05-15 15:42:27,818 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.216 has 3598.0 MB, 3.5 cpus
2018-05-15 15:42:27,818 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.217 has 3374.0 MB, 2.6 cpus
2018-05-15 15:42:27,818 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.236 has 13966.0 MB, 3.3 cpus
2018-05-15 15:42:27,818 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.203 has 4654.0 MB, 3.3 cpus
2018-05-15 15:42:27,818 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.204 has 4142.0 MB, 1.9 cpus
2018-05-15 15:42:27,818 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.218 has 302.0 MB, 1.4 cpus
2018-05-15 15:42:27,819 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.219 has 4910.0 MB, 2.8 cpus
2018-05-15 15:42:27,819 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 3 task(s) are not yet launched.
2018-05-15 15:42:32,839 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 3 task(s) against 0 new offer(s) plus outstanding offers.
2018-05-15 15:42:32,840 ERROR com.netflix.fenzo.TaskScheduler - Unexpected during concurrent task assignment eval - java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
java.util.concurrent.ExecutionException: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at com.netflix.fenzo.TaskScheduler.doSchedule(TaskScheduler.java:678)
at com.netflix.fenzo.TaskScheduler.scheduleOnce(TaskScheduler.java:600)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:173)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:144)
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at akka.actor.FSM$class.processEvent(FSM.scala:663)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.processEvent(LaunchCoordinator.scala:48)
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:657)
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:617)
at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.aroundReceive(LaunchCoordinator.scala:48)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
at akka.actor.ActorCell.invoke(ActorCell.scala:495)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at com.netflix.fenzo.AssignableVirtualMachine.findFailedHardConstraints(AssignableVirtualMachine.java:784)
at com.netflix.fenzo.AssignableVirtualMachine.tryRequest(AssignableVirtualMachine.java:581)
at com.netflix.fenzo.TaskScheduler.evalAssignments(TaskScheduler.java:796)
at com.netflix.fenzo.TaskScheduler.access$1500(TaskScheduler.java:70)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:670)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:667)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2018-05-15 15:42:32,842 ERROR com.netflix.fenzo.TaskScheduler - Unexpected during concurrent task assignment eval - java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
java.util.concurrent.ExecutionException: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at com.netflix.fenzo.TaskScheduler.doSchedule(TaskScheduler.java:678)
at com.netflix.fenzo.TaskScheduler.scheduleOnce(TaskScheduler.java:600)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:173)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:144)
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at akka.actor.FSM$class.processEvent(FSM.scala:663)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.processEvent(LaunchCoordinator.scala:48)
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:657)
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:617)
at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.aroundReceive(LaunchCoordinator.scala:48)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
at akka.actor.ActorCell.invoke(ActorCell.scala:495)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at com.netflix.fenzo.AssignableVirtualMachine.findFailedHardConstraints(AssignableVirtualMachine.java:784)
at com.netflix.fenzo.AssignableVirtualMachine.tryRequest(AssignableVirtualMachine.java:581)
at com.netflix.fenzo.TaskScheduler.evalAssignments(TaskScheduler.java:796)
at com.netflix.fenzo.TaskScheduler.access$1500(TaskScheduler.java:70)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:670)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:667)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2018-05-15 15:42:32,843 ERROR com.netflix.fenzo.TaskScheduler - Unexpected during concurrent task assignment eval - java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
java.util.concurrent.ExecutionException: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at com.netflix.fenzo.TaskScheduler.doSchedule(TaskScheduler.java:678)
at com.netflix.fenzo.TaskScheduler.scheduleOnce(TaskScheduler.java:600)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:173)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:144)
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at akka.actor.FSM$class.processEvent(FSM.scala:663)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.processEvent(LaunchCoordinator.scala:48)
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:657)
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:617)
at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.aroundReceive(LaunchCoordinator.scala:48)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
at akka.actor.ActorCell.invoke(ActorCell.scala:495)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at com.netflix.fenzo.AssignableVirtualMachine.findFailedHardConstraints(AssignableVirtualMachine.java:784)
at com.netflix.fenzo.AssignableVirtualMachine.tryRequest(AssignableVirtualMachine.java:581)
at com.netflix.fenzo.TaskScheduler.evalAssignments(TaskScheduler.java:796)
at com.netflix.fenzo.TaskScheduler.access$1500(TaskScheduler.java:70)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:670)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:667)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2018-05-15 15:42:32,844 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below)
2018-05-15 15:42:32,844 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.231 has 14478.0 MB, 3.6 cpus
2018-05-15 15:42:32,844 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.234 has 13166.0 MB, 3.1 cpus
2018-05-15 15:42:32,844 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.201 has 1902.0 MB, 2.8 cpus
2018-05-15 15:42:32,844 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.235 has 14478.0 MB, 3.6 cpus
2018-05-15 15:42:32,844 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.202 has 1326.0 MB, 3.2 cpus
2018-05-15 15:42:32,844 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.232 has 13966.0 MB, 3.6 cpus
2018-05-15 15:42:32,845 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.233 has 12910.0 MB, 2.9 cpus
2018-05-15 15:42:32,845 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.216 has 3598.0 MB, 3.5 cpus
2018-05-15 15:42:32,845 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.217 has 3374.0 MB, 2.6 cpus
2018-05-15 15:42:32,845 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.236 has 13966.0 MB, 3.3 cpus
2018-05-15 15:42:32,845 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.203 has 4654.0 MB, 3.3 cpus
2018-05-15 15:42:32,845 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.204 has 4142.0 MB, 1.9 cpus
2018-05-15 15:42:32,845 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.218 has 302.0 MB, 1.4 cpus
2018-05-15 15:42:32,845 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.219 has 4910.0 MB, 2.8 cpus
2018-05-15 15:42:32,845 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 3 task(s) are not yet launched.
2018-05-15 15:42:37,869 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 3 task(s) against 0 new offer(s) plus outstanding offers.
2018-05-15 15:42:37,870 ERROR com.netflix.fenzo.TaskScheduler - Unexpected during concurrent task assignment eval - java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
java.util.concurrent.ExecutionException: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at com.netflix.fenzo.TaskScheduler.doSchedule(TaskScheduler.java:678)
at com.netflix.fenzo.TaskScheduler.scheduleOnce(TaskScheduler.java:600)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:173)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:144)
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at akka.actor.FSM$class.processEvent(FSM.scala:663)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.processEvent(LaunchCoordinator.scala:48)
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:657)
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:617)
at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.aroundReceive(LaunchCoordinator.scala:48)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
at akka.actor.ActorCell.invoke(ActorCell.scala:495)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at com.netflix.fenzo.AssignableVirtualMachine.findFailedHardConstraints(AssignableVirtualMachine.java:784)
at com.netflix.fenzo.AssignableVirtualMachine.tryRequest(AssignableVirtualMachine.java:581)
at com.netflix.fenzo.TaskScheduler.evalAssignments(TaskScheduler.java:796)
at com.netflix.fenzo.TaskScheduler.access$1500(TaskScheduler.java:70)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:670)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:667)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2018-05-15 15:42:37,871 ERROR com.netflix.fenzo.TaskScheduler - Unexpected during concurrent task assignment eval - java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
java.util.concurrent.ExecutionException: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at com.netflix.fenzo.TaskScheduler.doSchedule(TaskScheduler.java:678)
at com.netflix.fenzo.TaskScheduler.scheduleOnce(TaskScheduler.java:600)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:173)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:144)
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at akka.actor.FSM$class.processEvent(FSM.scala:663)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.processEvent(LaunchCoordinator.scala:48)
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:657)
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:617)
at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.aroundReceive(LaunchCoordinator.scala:48)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
at akka.actor.ActorCell.invoke(ActorCell.scala:495)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at com.netflix.fenzo.AssignableVirtualMachine.findFailedHardConstraints(AssignableVirtualMachine.java:784)
at com.netflix.fenzo.AssignableVirtualMachine.tryRequest(AssignableVirtualMachine.java:581)
at com.netflix.fenzo.TaskScheduler.evalAssignments(TaskScheduler.java:796)
at com.netflix.fenzo.TaskScheduler.access$1500(TaskScheduler.java:70)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:670)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:667)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2018-05-15 15:42:37,872 ERROR com.netflix.fenzo.TaskScheduler - Unexpected during concurrent task assignment eval - java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
java.util.concurrent.ExecutionException: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at com.netflix.fenzo.TaskScheduler.doSchedule(TaskScheduler.java:678)
at com.netflix.fenzo.TaskScheduler.scheduleOnce(TaskScheduler.java:600)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:173)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:144)
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at akka.actor.FSM$class.processEvent(FSM.scala:663)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.processEvent(LaunchCoordinator.scala:48)
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:657)
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:617)
at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.aroundReceive(LaunchCoordinator.scala:48)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
at akka.actor.ActorCell.invoke(ActorCell.scala:495)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at com.netflix.fenzo.AssignableVirtualMachine.findFailedHardConstraints(AssignableVirtualMachine.java:784)
at com.netflix.fenzo.AssignableVirtualMachine.tryRequest(AssignableVirtualMachine.java:581)
at com.netflix.fenzo.TaskScheduler.evalAssignments(TaskScheduler.java:796)
at com.netflix.fenzo.TaskScheduler.access$1500(TaskScheduler.java:70)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:670)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:667)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2018-05-15 15:42:37,872 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below)
2018-05-15 15:42:37,873 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.231 has 14478.0 MB, 3.6 cpus
2018-05-15 15:42:37,873 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.234 has 13166.0 MB, 3.1 cpus
2018-05-15 15:42:37,873 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.201 has 1902.0 MB, 2.8 cpus
2018-05-15 15:42:37,873 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.235 has 14478.0 MB, 3.6 cpus
2018-05-15 15:42:37,873 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.202 has 1326.0 MB, 3.2 cpus
2018-05-15 15:42:37,873 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.232 has 13966.0 MB, 3.6 cpus
2018-05-15 15:42:37,873 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.233 has 12910.0 MB, 2.9 cpus
2018-05-15 15:42:37,873 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.216 has 3598.0 MB, 3.5 cpus
2018-05-15 15:42:37,873 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.217 has 3374.0 MB, 2.6 cpus
2018-05-15 15:42:37,873 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.236 has 13966.0 MB, 3.3 cpus
2018-05-15 15:42:37,874 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.203 has 4654.0 MB, 3.3 cpus
2018-05-15 15:42:37,874 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.204 has 4142.0 MB, 1.9 cpus
2018-05-15 15:42:37,874 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.218 has 302.0 MB, 1.4 cpus
2018-05-15 15:42:37,874 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.219 has 4910.0 MB, 2.8 cpus
2018-05-15 15:42:37,874 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 3 task(s) are not yet launched.
2018-05-15 15:42:42,889 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 3 task(s) against 0 new offer(s) plus outstanding offers.
2018-05-15 15:42:42,891 ERROR com.netflix.fenzo.TaskScheduler - Unexpected during concurrent task assignment eval - java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
java.util.concurrent.ExecutionException: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at com.netflix.fenzo.TaskScheduler.doSchedule(TaskScheduler.java:678)
at com.netflix.fenzo.TaskScheduler.scheduleOnce(TaskScheduler.java:600)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:173)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:144)
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at akka.actor.FSM$class.processEvent(FSM.scala:663)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.processEvent(LaunchCoordinator.scala:48)
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:657)
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:617)
at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.aroundReceive(LaunchCoordinator.scala:48)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
at akka.actor.ActorCell.invoke(ActorCell.scala:495)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at com.netflix.fenzo.AssignableVirtualMachine.findFailedHardConstraints(AssignableVirtualMachine.java:784)
at com.netflix.fenzo.AssignableVirtualMachine.tryRequest(AssignableVirtualMachine.java:581)
at com.netflix.fenzo.TaskScheduler.evalAssignments(TaskScheduler.java:796)
at com.netflix.fenzo.TaskScheduler.access$1500(TaskScheduler.java:70)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:670)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:667)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2018-05-15 15:42:42,892 ERROR com.netflix.fenzo.TaskScheduler - Unexpected during concurrent task assignment eval - java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
java.util.concurrent.ExecutionException: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at com.netflix.fenzo.TaskScheduler.doSchedule(TaskScheduler.java:678)
at com.netflix.fenzo.TaskScheduler.scheduleOnce(TaskScheduler.java:600)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:173)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:144)
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at akka.actor.FSM$class.processEvent(FSM.scala:663)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.processEvent(LaunchCoordinator.scala:48)
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:657)
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:617)
at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.aroundReceive(LaunchCoordinator.scala:48)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
at akka.actor.ActorCell.invoke(ActorCell.scala:495)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at com.netflix.fenzo.AssignableVirtualMachine.findFailedHardConstraints(AssignableVirtualMachine.java:784)
at com.netflix.fenzo.AssignableVirtualMachine.tryRequest(AssignableVirtualMachine.java:581)
at com.netflix.fenzo.TaskScheduler.evalAssignments(TaskScheduler.java:796)
at com.netflix.fenzo.TaskScheduler.access$1500(TaskScheduler.java:70)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:670)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:667)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2018-05-15 15:42:42,896 ERROR com.netflix.fenzo.TaskScheduler - Unexpected during concurrent task assignment eval - java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
java.util.concurrent.ExecutionException: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at com.netflix.fenzo.TaskScheduler.doSchedule(TaskScheduler.java:678)
at com.netflix.fenzo.TaskScheduler.scheduleOnce(TaskScheduler.java:600)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:173)
at org.apache.flink.mesos.scheduler.LaunchCoordinator$$anonfun$5.applyOrElse(LaunchCoordinator.scala:144)
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
at akka.actor.FSM$class.processEvent(FSM.scala:663)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.processEvent(LaunchCoordinator.scala:48)
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:657)
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:617)
at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
at org.apache.flink.mesos.scheduler.LaunchCoordinator.aroundReceive(LaunchCoordinator.scala:48)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
at akka.actor.ActorCell.invoke(ActorCell.scala:495)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.NoClassDefFoundError: Could not initialize class com.netflix.fenzo.ConstraintFailure
at com.netflix.fenzo.AssignableVirtualMachine.findFailedHardConstraints(AssignableVirtualMachine.java:784)
at com.netflix.fenzo.AssignableVirtualMachine.tryRequest(AssignableVirtualMachine.java:581)
at com.netflix.fenzo.TaskScheduler.evalAssignments(TaskScheduler.java:796)
at com.netflix.fenzo.TaskScheduler.access$1500(TaskScheduler.java:70)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:670)
at com.netflix.fenzo.TaskScheduler$1.call(TaskScheduler.java:667)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2018-05-15 15:42:42,897 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below)
2018-05-15 15:42:42,897 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.231 has 14478.0 MB, 3.6 cpus
2018-05-15 15:42:42,897 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.234 has 13166.0 MB, 3.1 cpus
2018-05-15 15:42:42,897 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.201 has 1902.0 MB, 2.8 cpus
2018-05-15 15:42:42,897 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.235 has 14478.0 MB, 3.6 cpus
2018-05-15 15:42:42,897 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.202 has 1326.0 MB, 3.2 cpus
2018-05-15 15:42:42,897 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.232 has 13966.0 MB, 3.6 cpus
2018-05-15 15:42:42,897 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.233 has 12910.0 MB, 2.9 cpus
2018-05-15 15:42:42,898 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.216 has 3598.0 MB, 3.5 cpus
2018-05-15 15:42:42,898 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.217 has 3374.0 MB, 2.6 cpus
2018-05-15 15:42:42,898 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.236 has 13966.0 MB, 3.3 cpus
2018-05-15 15:42:42,898 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.203 has 4654.0 MB, 3.3 cpus
2018-05-15 15:42:42,898 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.204 has 4142.0 MB, 1.9 cpus
2018-05-15 15:42:42,898 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.218 has 302.0 MB, 1.4 cpus
2018-05-15 15:42:42,898 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 172.29.6.219 has 4910.0 MB, 2.8 cpus
2018-05-15 15:42:42,898 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 3 task(s) are not yet launched.
```
---