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

Align the desired and sufficient resources definiton in Executing and WaitForResources states

    XMLWordPrintableJSON

Details

    • Hide
      The new configuration `jobmanager.adaptive-scheduler.executing.resource-stabilization-timeout` for the AdaptiveScheduler was introduced. It defines a duration for which the JobManager delays the scaling operation after a resource change if only sufficient resources are available.

      The existing configuration `jobmanager.adaptive-scheduler.min-parallelism-increase` was deprecated and is not used by Flink anymore.

      See Flink's configuration documentation for further details.
      Show
      The new configuration `jobmanager.adaptive-scheduler.executing.resource-stabilization-timeout` for the AdaptiveScheduler was introduced. It defines a duration for which the JobManager delays the scaling operation after a resource change if only sufficient resources are available. The existing configuration `jobmanager.adaptive-scheduler.min-parallelism-increase` was deprecated and is not used by Flink anymore. See Flink's configuration documentation for further details.

    Description

      The goal is to use the same definition for the desired and sufficient resources in the Executing state as in the WaitingForResources state. 

      Attachments

        Issue Links

          Activity

            People

              ztison Zdenek Tison
              ztison Zdenek Tison
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: