How to simulate a blocking (sink) node?

[tison]

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.