[
https://issues.apache.org/jira/browse/FLINK-31071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang updated FLINK-31071:
-------------------------------
Description:
This task aims to verify [FLIP-283 Use adaptive batch scheduler as default
scheduler for batch jobs|https://issues.apache.org/jira/browse/FLINK-30682].
The documentation of adaptive batch scheduler can be found
[here|https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/elastic_scaling/#adaptive-batch-scheduler]
.
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}}) are in 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.
was:
This task aims to verify [FLIP-283 Use adaptive batch scheduler as default
scheduler for batch jobs|https://issues.apache.org/jira/browse/FLINK-30682].
The documentation of adaptive batch scheduler can be found
[here|https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/elastic_scaling/#adaptive-batch-scheduler]
.
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) are in 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.
> Release Testing: Verify FLIP-283 Use adaptive batch scheduler as default
> scheduler for batch jobs
> -------------------------------------------------------------------------------------------------
>
> Key: FLINK-31071
> URL: https://issues.apache.org/jira/browse/FLINK-31071
> Project: Flink
> Issue Type: Sub-task
> Reporter: Lijie Wang
> Priority: Major
>
> This task aims to verify [FLIP-283 Use adaptive batch scheduler as default
> scheduler for batch jobs|https://issues.apache.org/jira/browse/FLINK-30682].
> The documentation of adaptive batch scheduler can be found
> [here|https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/elastic_scaling/#adaptive-batch-scheduler]
> .
> 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}}) are in 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.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
