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.

WeirdJob.java
Description: Binary data

jobmanager.log
Description: Binary data