You are welcome :) Piotrek
> On Oct 2, 2017, at 1:19 PM, yunfan123 <yunfanfight...@foxmail.com> wrote: > > Thank you. > "If SourceFunction.run methods returns without an exception Flink assumes > that it has cleanly shutdown and that there were simply no more elements to > collect/create by this task. " > This sentence solve my confusion. > > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/