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

Iterative job with maxWaitTimeMillis does not terminate

    XMLWordPrintableJSON

Details

    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

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

              Dates

                Created:
                Updated: