diff --git a/docs/content.zh/docs/core-concept/data-pipeline.md b/docs/content.zh/docs/core-concept/data-pipeline.md index 3903c922b0..b9745e8823 100644 --- 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 | \ No newline at end of file diff --git a/docs/content/docs/core-concept/data-pipeline.md b/docs/content/docs/core-concept/data-pipeline.md index 3903c922b0..b9745e8823 100644 --- 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 | \ No newline at end of file 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 index ed5f6e9c06..5c32a0290f 100644 --- 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 PIPELINE_PARALLELISM = ConfigOptions.key("parallelism") .intType() - .noDefaultValue() + .defaultValue(1) .withDescription("Parallelism of the pipeline"); public static final ConfigOption PIPELINE_SCHEMA_CHANGE_BEHAVIOR =