Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-30926 [Umbrella] Test Flink Release 1.17
  3. FLINK-31071

Release Testing: Verify FLIP-283 Use adaptive batch scheduler as default scheduler for batch jobs

    XMLWordPrintableJSON

Details

    Description

      This task aims to verify FLIP-283 Use adaptive batch scheduler as default scheduler for batch jobs.
      The documentation of adaptive batch scheduler can be found here .

      Things to verify:

      1. Verify the adaptive batch scheduler is the default scheduler of batch jobs. By default, Flink will automatically decide parallelism for operators of batch jobs if the scheduler is not specified.

      2. Verify the configuration options(execution.batch.adaptive.auto-parallelism.xxx) take effect. Besides, it is also necessary to verify that the default parallelism set via parallelism.default or StreamExecutionEnvironment#setParallelism() will be used as upper bound of allowed parallelism if the execution.batch.adaptive.auto-parallelism.max-parallelism is not configured.

      3. Verify the final data produced are correct.

      Attachments

        Activity

          People

            xiasun xingbe
            wanglijie Lijie Wang
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: