From 08ed217640dee7c6eddb629a1c19260af5a8c5b3 Mon Sep 17 00:00:00 2001 From: yuxiqian <34335406+yuxiqian@users.noreply.github.com> Date: Fri, 12 Jul 2024 17:42:26 +0800 Subject: [PATCH] [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 +- .../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 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 =