You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by sgran <gi...@git.apache.org> on 2017/04/20 09:28:06 UTC
[GitHub] flink pull request #3744: [FLINK-6336] Initial commit of mesos placement con...
GitHub user sgran opened a pull request:
https://github.com/apache/flink/pull/3744
[FLINK-6336] Initial commit of mesos placement constraints
This adds a HostAttrValueConstraint evaluator for fenzo, allowing tasks
to be placed on agents with matching attributes.
Signed-off-by: Stephen Gran <st...@piksel.com>
Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.
If your changes take all of the items into account, feel free to open your pull request. For more information and/or questions please refer to the [How To Contribute guide](http://flink.apache.org/how-to-contribute.html).
In addition to going through the list, please provide a meaningful description of your changes.
- [ ] General
- The pull request references the related JIRA issue ("[FLINK-XXX] Jira title text")
- The pull request addresses only one issue
- Each commit in the PR has a meaningful commit message (including the JIRA id)
- [ ] Documentation
- Documentation has been added for new functionality
- Old documentation affected by the pull request has been updated
- JavaDoc for public methods has been added
- [ ] Tests & Build
- Functionality added by the pull request is covered by tests
- `mvn clean verify` has been executed successfully locally or a Travis build has passed
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/pikselpalette/flink add_constraints
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3744.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3744
----
commit c0e180195336fdd030243f27c4a954a28a1f6a1e
Author: Stephen Gran <st...@piksel.com>
Date: 2017-04-20T09:22:08Z
Initial commit of mesos placement constraints
This adds a HostAttrValueConstraint evaluator for fenzo, allowing tasks
to be placed on agents with matching attributes.
Signed-off-by: Stephen Gran <st...@piksel.com>
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] flink pull request #3744: [FLINK-6336] Initial commit of mesos placement con...
Posted by asfgit <gi...@git.apache.org>.
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3744
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] flink issue #3744: [FLINK-6336] Initial commit of mesos placement constraint...
Posted by rsingh2411 <gi...@git.apache.org>.
Github user rsingh2411 commented on the issue:
https://github.com/apache/flink/pull/3744
Getting similar error, whileadding Unique host constraint. How did you fix that
imestamp=2018-05-16 10:52:34,105 LogLevel=ERROR ThreadId=[flink-akka.actor.default-dispatcher-3] Class=c.n.f.TaskScheduler Msg=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
---
[GitHub] flink issue #3744: [FLINK-6336] Initial commit of mesos placement constraint...
Posted by sgran <gi...@git.apache.org>.
Github user sgran commented on the issue:
https://github.com/apache/flink/pull/3744
I wish there was a way to re-trigger the test suite without closing and reopening the merge request. It seems a bit of a blunt hammer.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] flink pull request #3744: [FLINK-6336] Initial commit of mesos placement con...
Posted by sgran <gi...@git.apache.org>.
Github user sgran closed the pull request at:
https://github.com/apache/flink/pull/3744
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] flink pull request #3744: [FLINK-6336] Initial commit of mesos placement con...
Posted by sgran <gi...@git.apache.org>.
Github user sgran closed the pull request at:
https://github.com/apache/flink/pull/3744
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] flink pull request #3744: [FLINK-6336] Initial commit of mesos placement con...
Posted by sgran <gi...@git.apache.org>.
Github user sgran closed the pull request at:
https://github.com/apache/flink/pull/3744
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] flink pull request #3744: [FLINK-6336] Initial commit of mesos placement con...
Posted by EronWright <gi...@git.apache.org>.
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/3744#discussion_r112486557
--- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -487,6 +487,11 @@
public static final String MESOS_INITIAL_TASKS = "mesos.initial-tasks";
/**
+ * Constraints for placement of Mesos tasks.
+ */
+ public static final String MESOS_CONSTRAINTS = "mesos.constraints.hard.hostattribute";
--- End diff --
Please remove this constant, since you're using the new ConfigOption approach which doesn't necessitate an entry here.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] flink issue #3744: [FLINK-6336] Initial commit of mesos placement constraint...
Posted by tillrohrmann <gi...@git.apache.org>.
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/3744
Thanks for your contribution @sgran and the review @EronWright. Changes look good to me. Merging this PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] flink pull request #3744: [FLINK-6336] Initial commit of mesos placement con...
Posted by sgran <gi...@git.apache.org>.
GitHub user sgran reopened a pull request:
https://github.com/apache/flink/pull/3744
[FLINK-6336] Initial commit of mesos placement constraints
This adds a HostAttrValueConstraint evaluator for fenzo, allowing tasks
to be placed on agents with matching attributes.
Signed-off-by: Stephen Gran <st...@piksel.com>
Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.
If your changes take all of the items into account, feel free to open your pull request. For more information and/or questions please refer to the [How To Contribute guide](http://flink.apache.org/how-to-contribute.html).
In addition to going through the list, please provide a meaningful description of your changes.
- [x] General
- The pull request references the related JIRA issue ("[FLINK-XXX] Jira title text")
- The pull request addresses only one issue
- Each commit in the PR has a meaningful commit message (including the JIRA id)
- [x] Documentation
- Documentation has been added for new functionality
- Old documentation affected by the pull request has been updated
- JavaDoc for public methods has been added
- [x] Tests & Build
- Functionality added by the pull request is covered by tests
- `mvn clean verify` has been executed successfully locally or a Travis build has passed
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/pikselpalette/flink add_constraints
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3744.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3744
----
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] flink issue #3744: [FLINK-6336] Initial commit of mesos placement constraint...
Posted by kikicarbonell <gi...@git.apache.org>.
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.
```
---
[GitHub] flink pull request #3744: [FLINK-6336] Initial commit of mesos placement con...
Posted by sgran <gi...@git.apache.org>.
GitHub user sgran reopened a pull request:
https://github.com/apache/flink/pull/3744
[FLINK-6336] Initial commit of mesos placement constraints
This adds a HostAttrValueConstraint evaluator for fenzo, allowing tasks
to be placed on agents with matching attributes.
Signed-off-by: Stephen Gran <st...@piksel.com>
Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.
If your changes take all of the items into account, feel free to open your pull request. For more information and/or questions please refer to the [How To Contribute guide](http://flink.apache.org/how-to-contribute.html).
In addition to going through the list, please provide a meaningful description of your changes.
- [x] General
- The pull request references the related JIRA issue ("[FLINK-XXX] Jira title text")
- The pull request addresses only one issue
- Each commit in the PR has a meaningful commit message (including the JIRA id)
- [x] Documentation
- Documentation has been added for new functionality
- Old documentation affected by the pull request has been updated
- JavaDoc for public methods has been added
- [x] Tests & Build
- Functionality added by the pull request is covered by tests
- `mvn clean verify` has been executed successfully locally or a Travis build has passed
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/pikselpalette/flink add_constraints
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3744.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3744
----
commit c0e180195336fdd030243f27c4a954a28a1f6a1e
Author: Stephen Gran <st...@piksel.com>
Date: 2017-04-20T09:22:08Z
Initial commit of mesos placement constraints
This adds a HostAttrValueConstraint evaluator for fenzo, allowing tasks
to be placed on agents with matching attributes.
Signed-off-by: Stephen Gran <st...@piksel.com>
commit 709cfe5bd3464327b8d24322830d20a20be6e557
Author: Stephen Gran <st...@piksel.com>
Date: 2017-04-21T06:17:44Z
Better docs - add examples
Signed-off-by: Stephen Gran <st...@piksel.com>
commit fc87105ab30c129f70d6cc34724720a3919cde96
Author: Stephen Gran <st...@piksel.com>
Date: 2017-04-21T06:17:47Z
Drop unnecessary constant
Signed-off-by: Stephen Gran <st...@piksel.com>
commit 154c11930b0c7fd1be5346e67a7486fbf4c3c4ad
Author: Stephen Gran <st...@piksel.com>
Date: 2017-04-21T06:19:04Z
clarify basis for task placement constraints
Signed-off-by: Stephen Gran <st...@piksel.com>
commit 797736c608cc70448f73f90853440236a093f2f0
Author: Stephen Gran <st...@piksel.com>
Date: 2017-04-21T06:37:50Z
drop unused import
Signed-off-by: Stephen Gran <st...@piksel.com>
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] flink pull request #3744: [FLINK-6336] Initial commit of mesos placement con...
Posted by sgran <gi...@git.apache.org>.
GitHub user sgran reopened a pull request:
https://github.com/apache/flink/pull/3744
[FLINK-6336] Initial commit of mesos placement constraints
This adds a HostAttrValueConstraint evaluator for fenzo, allowing tasks
to be placed on agents with matching attributes.
Signed-off-by: Stephen Gran <st...@piksel.com>
Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.
If your changes take all of the items into account, feel free to open your pull request. For more information and/or questions please refer to the [How To Contribute guide](http://flink.apache.org/how-to-contribute.html).
In addition to going through the list, please provide a meaningful description of your changes.
- [x] General
- The pull request references the related JIRA issue ("[FLINK-XXX] Jira title text")
- The pull request addresses only one issue
- Each commit in the PR has a meaningful commit message (including the JIRA id)
- [x] Documentation
- Documentation has been added for new functionality
- Old documentation affected by the pull request has been updated
- JavaDoc for public methods has been added
- [x] Tests & Build
- Functionality added by the pull request is covered by tests
- `mvn clean verify` has been executed successfully locally or a Travis build has passed
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/pikselpalette/flink add_constraints
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3744.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3744
----
commit c0e180195336fdd030243f27c4a954a28a1f6a1e
Author: Stephen Gran <st...@piksel.com>
Date: 2017-04-20T09:22:08Z
Initial commit of mesos placement constraints
This adds a HostAttrValueConstraint evaluator for fenzo, allowing tasks
to be placed on agents with matching attributes.
Signed-off-by: Stephen Gran <st...@piksel.com>
commit 709cfe5bd3464327b8d24322830d20a20be6e557
Author: Stephen Gran <st...@piksel.com>
Date: 2017-04-21T06:17:44Z
Better docs - add examples
Signed-off-by: Stephen Gran <st...@piksel.com>
commit fc87105ab30c129f70d6cc34724720a3919cde96
Author: Stephen Gran <st...@piksel.com>
Date: 2017-04-21T06:17:47Z
Drop unnecessary constant
Signed-off-by: Stephen Gran <st...@piksel.com>
commit 154c11930b0c7fd1be5346e67a7486fbf4c3c4ad
Author: Stephen Gran <st...@piksel.com>
Date: 2017-04-21T06:19:04Z
clarify basis for task placement constraints
Signed-off-by: Stephen Gran <st...@piksel.com>
commit 797736c608cc70448f73f90853440236a093f2f0
Author: Stephen Gran <st...@piksel.com>
Date: 2017-04-21T06:37:50Z
drop unused import
Signed-off-by: Stephen Gran <st...@piksel.com>
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] flink pull request #3744: [FLINK-6336] Initial commit of mesos placement con...
Posted by EronWright <gi...@git.apache.org>.
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/3744#discussion_r112487388
--- Diff: docs/setup/mesos.md ---
@@ -222,6 +222,8 @@ When running Flink with Marathon, the whole Flink cluster including the job mana
`mesos.initial-tasks`: The initial workers to bring up when the master starts (**DEFAULT**: The number of workers specified at cluster startup).
+`mesos.constraints.hard.hostattribute`: Constraints for task placement on mesos (**DEFAULT**: None).
--- End diff --
The description seems too generic; I suggest `Constraints for task placement on mesos based on host attributes`. An inline example would also be nice, or at least some description of the value format.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---