Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-20305

Iterative job with maxWaitTimeMillis does not terminate

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 1.12.0
    • Fix Version/s: 1.13.0
    • Component/s: API / DataStream
    • Labels:

      Description

      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.

        Attachments

          Issue Links

          relates to

          Sub-task - The sub-task of the issue FLINK-20115 Test Batch execution for the DataStream API 

          • Critical - Crashes, loss of data, severe memory leak.
          • Closed

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                trohrmann Till Rohrmann
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated: