This is an automated email from the ASF dual-hosted git repository.
leonard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new a098ddacb [FLINK-35781][cli] Provide a default parallelism 1 for
pipeline jobs
a098ddacb is described below
commit a098ddacbaafdf417ba080200d8a96d6c14156a3
Author: yuxiqian <[email protected]>
AuthorDate: Fri Jul 12 17:42:26 2024 +0800
[FLINK-35781][cli] Provide a default parallelism 1 for pipeline jobs
This closes #3458.
---
docs/content.zh/docs/core-concept/data-pipeline.md | 2 +-
docs/content/docs/core-concept/data-pipeline.md | 2 +-
.../main/java/org/apache/flink/cdc/common/pipeline/PipelineOptions.java | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/docs/content.zh/docs/core-concept/data-pipeline.md
b/docs/content.zh/docs/core-concept/data-pipeline.md
index 3903c922b..b9745e882 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 3903c922b..b9745e882 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 ed5f6e9c0..5c32a0290 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<Integer> PIPELINE_PARALLELISM =
ConfigOptions.key("parallelism")
.intType()
- .noDefaultValue()
+ .defaultValue(1)
.withDescription("Parallelism of the pipeline");
public static final ConfigOption<SchemaChangeBehavior>
PIPELINE_SCHEMA_CHANGE_BEHAVIOR =
