You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by 陈梓立 <wa...@gmail.com> on 2018/09/06 02:30:26 UTC

How to simulate a blocking (sink) node?

Hi all,

Recently I want to write a test in a batch case that some of tasks are
FINISHED.

I try to write a finite SourceFunction and a (expected) blocking
SinkFunction. But the job FINISHED. This surprises me. Why could the Sink
FINISHED in such a case?

The job and log are attached.

Best,
tison.