[
https://issues.apache.org/jira/browse/FLINK-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476038#comment-16476038
]
ASF GitHub Bot commented on FLINK-6336:
---------------------------------------
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.
```
> Placement Constraints for Mesos
> -------------------------------
>
> Key: FLINK-6336
> URL: https://issues.apache.org/jira/browse/FLINK-6336
> Project: Flink
> Issue Type: New Feature
> Components: Mesos
> Affects Versions: 1.2.0
> Reporter: Stephen Gran
> Assignee: Stephen Gran
> Priority: Minor
> Fix For: 1.3.0
>
>
> Fenzo supports placement constraints for tasks, and operators expose agent
> attributes to frameworks in the form of attributes about the agent offer.
> It would be extremely helpful in our multi-tenant cluster to be able to make
> use of this facility.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
