Re: Consult about flink on mesos cluster

2017-10-10 Thread Till Rohrmann
Hi Bo, I think the by saying mesos.constraings.hard.hostattribute: rack:ak03-07,rack:ak16-10, you define two hard constraints which are attribute rack must equal ak03-07 AND rack must equal ak16-10. Since a task offer must come from both racks, it will never complete a task request. So at the mome

Re: Consult about flink on mesos cluster

2017-10-09 Thread Bo Yu
Thanks, Till I tried to set hard host attribute constraints in "flink-conf.yaml" as mesos.constraints.hard.hostattribute: rack:ak03-07,rack:ak16-10,rack:ak03-04 where "rack:akXX-XX" is the MESOS_attributes of each slave. Then I get to the situation that the mesos app master doesn't accept the off

Re: Consult about flink on mesos cluster

2017-10-09 Thread Till Rohrmann
Hi Bo, you can still use Flink with Marathon, because Marathon will only schedule the cluster entrypoint which is the MesosApplicationMasterRunner. Everything else will be scheduled via Fenzo. Moreover, by using Marathon you gain high availability because Marathon makes sure that the ApplicationMa

Re: Consult about flink on mesos cluster

2017-10-09 Thread yubo
Thanks for your reply, Till We will use without Marathon, and hope the PR is merged to latest version soon. Best regards, Bo > On Oct 9, 29 Heisei, at 6:36 PM, Till Rohrmann wrote: > > Hi Bo, > > Flink uses internally Fenzo to match tasks and offers. Fenzo does not support > the Marathon con