Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-35035 Reduce job pause time when cluster resources are expanded in adaptive mode
  3. FLINK-36168

AdaptiveSchedulerTest doesn't follow the production lifecycle

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 2.0-preview
    • None

    Description

      The AdaptiveSchedulerTest doesn't follow the production lifecycle properly: The executor representing the main thread is shutting down before the AdaptiveScheduler is closed (or more precisely, the scheduler isn't closed at all in most of the tests).

      This can cause issues when shutting down the executor and tasks still being scheduled and not properly cleaned up. This issue is about fixing the test in this regards.

      Attachments

        Issue Links

          causes

          Sub-task - The sub-task of the issue FLINK-36299 AdaptiveSchedulerTest.testStatusMetrics times out

          • Critical - Crashes, loss of data, severe memory leak.
          • Resolved
          links to

          Web Link GitHub Pull Request #25260

          Web Link GitHub Pull Request #25305

          Activity

            People

              ztison Zdenek Tison
              mapohl Matthias Pohl
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: