[FLINK-35781][cli] Provide a default parallelism 1 for pipeline jobs

This closes apache#3458.
qiaozongmi · Sep 23, 2024 · 08ed217 · 08ed217
1 parent 104be20
commit 08ed217
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/docs/content.zh/docs/core-concept/data-pipeline.md b/docs/content.zh/docs/core-concept/data-pipeline.md
@@ -98,5 +98,5 @@ The following config options of Data Pipeline level are supported:
 | parameter       | meaning                                                                                 | optional/required |
 |-----------------|-----------------------------------------------------------------------------------------|-------------------|
 | name            | The name of the pipeline, which will be submitted to the Flink cluster as the job name. | optional          |
-| parallelism     | The global parallelism of the pipeline.                                                 | required          |
+| parallelism     | The global parallelism of the pipeline. Defaults to 1.                                  | optional          |
 | local-time-zone | The local time zone defines current session time zone id.                               | optional          |
diff --git a/docs/content/docs/core-concept/data-pipeline.md b/docs/content/docs/core-concept/data-pipeline.md
@@ -98,5 +98,5 @@ The following config options of Data Pipeline level are supported:
 | parameter       | meaning                                                                                 | optional/required |
 |-----------------|-----------------------------------------------------------------------------------------|-------------------|
 | name            | The name of the pipeline, which will be submitted to the Flink cluster as the job name. | optional          |
-| parallelism     | The global parallelism of the pipeline.                                                 | required          |
+| parallelism     | The global parallelism of the pipeline. Defaults to 1.                                  | optional          |
 | local-time-zone | The local time zone defines current session time zone id.                               | optional          |
diff --git a/flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/PipelineOptions.java b/flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/PipelineOptions.java
@@ -42,7 +42,7 @@ public class PipelineOptions {
     public static final ConfigOption<Integer> PIPELINE_PARALLELISM =
             ConfigOptions.key("parallelism")
                     .intType()
-                    .noDefaultValue()
+                    .defaultValue(1)
                     .withDescription("Parallelism of the pipeline");
 
     public static final ConfigOption<SchemaChangeBehavior> PIPELINE_SCHEMA_CHANGE_BEHAVIOR =