Skip to content

Commit a098dda

Browse files
authored
[FLINK-35781][cli] Provide a default parallelism 1 for pipeline jobs
This closes #3458.
1 parent ad1f554 commit a098dda

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

docs/content.zh/docs/core-concept/data-pipeline.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -98,5 +98,5 @@ The following config options of Data Pipeline level are supported:
9898
| parameter | meaning | optional/required |
9999
|-----------------|-----------------------------------------------------------------------------------------|-------------------|
100100
| name | The name of the pipeline, which will be submitted to the Flink cluster as the job name. | optional |
101-
| parallelism | The global parallelism of the pipeline. | required |
101+
| parallelism | The global parallelism of the pipeline. Defaults to 1. | optional |
102102
| local-time-zone | The local time zone defines current session time zone id. | optional |

docs/content/docs/core-concept/data-pipeline.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -98,5 +98,5 @@ The following config options of Data Pipeline level are supported:
9898
| parameter | meaning | optional/required |
9999
|-----------------|-----------------------------------------------------------------------------------------|-------------------|
100100
| name | The name of the pipeline, which will be submitted to the Flink cluster as the job name. | optional |
101-
| parallelism | The global parallelism of the pipeline. | required |
101+
| parallelism | The global parallelism of the pipeline. Defaults to 1. | optional |
102102
| local-time-zone | The local time zone defines current session time zone id. | optional |

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/PipelineOptions.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ public class PipelineOptions {
4242
public static final ConfigOption<Integer> PIPELINE_PARALLELISM =
4343
ConfigOptions.key("parallelism")
4444
.intType()
45-
.noDefaultValue()
45+
.defaultValue(1)
4646
.withDescription("Parallelism of the pipeline");
4747

4848
public static final ConfigOption<SchemaChangeBehavior> PIPELINE_SCHEMA_CHANGE_BEHAVIOR =

0 commit comments

Comments
 (0)