Till Rohrmann created FLINK-20305:
-------------------------------------
Summary: Iterative job with maxWaitTimeMillis does not terminate
Key: FLINK-20305
URL:
https://issues.apache.org/jira/browse/FLINK-20305 Project: Flink
Issue Type: Bug
Components: API / DataStream
Reporter: Till Rohrmann
While testing the {{DataStream}} API, I noticed that an iterative job with {{maxWaitTimeMillis}} set, sometimes did not terminate depending on the used parallelism. Since I used a bounded source with few events, it looked a bit as if the iteration tasks couldn't terminate if they didn't receive an event. The corresponding testing job including test data can be found [here|
https://github.com/tillrohrmann/flink-streaming-batch-execution/tree/iteration-problem].
--
This message was sent by Atlassian Jira
(v8.3.4#803005)