There's no reasonable way to implement a custom Scheduler, i.e., something where can just plug in your scheduler in a nice way. For this you'll have to directly modify the source of Flink.
The work in https://issues.apache.org/jira/browse/FLINK-8886 may also be of interest, but is still in the design phase.
On 28.11.2018 10:21, Felipe Gutierrez wrote:
Hi, I want to develop a custom scheduler in Flink to be aware for which host Flink must process some task. This post shows (using Apache Storm) the kind of example I want to build ( https://inside.edited.com/taking-control-of-your-apache-storm-cluster-with-tag-aware-scheduling-b60aaaa5e37e ). I saw some related question on this post from 2016 ( http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/custom-scheduler-in-Flink-td7804.html) and I wonder if there is something more actual or better explained about a custom scheduler. Thanks, Felipe *--* *-- Felipe Gutierrez* *-- skype: felipe.o.gutierrez* *--* *https://felipeogutierrez.blogspot.com <https://felipeogutierrez.blogspot.com>*
| Free forum by Nabble | Edit this page |