To properly implement stop we have to change some internal orchestration structure. This is not a trivial task and so far nobody had found time to work on it. Moreover, the individual sources have to be adapted as well.
Cheers, Till On Thu, May 11, 2017 at 4:54 AM, yunfan123 <yunfanfight...@foxmail.com> wrote: > But why FlinkKafkaConsumerBase don't implement the StoppableFunction > interface? > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/Deactive-a-job- > like-storm-tp13088p13099.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
