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)
