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

This closes #3458.
pull/3429/head
yuxiqian 7 months ago committed by GitHub
parent ad1f554c0e
commit a098ddacba
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

@ -98,5 +98,5 @@ The following config options of Data Pipeline level are supported:
| parameter | meaning | optional/required | | parameter | meaning | optional/required |
|-----------------|-----------------------------------------------------------------------------------------|-------------------| |-----------------|-----------------------------------------------------------------------------------------|-------------------|
| name | The name of the pipeline, which will be submitted to the Flink cluster as the job name. | optional | | 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 | | local-time-zone | The local time zone defines current session time zone id. | optional |

@ -98,5 +98,5 @@ The following config options of Data Pipeline level are supported:
| parameter | meaning | optional/required | | parameter | meaning | optional/required |
|-----------------|-----------------------------------------------------------------------------------------|-------------------| |-----------------|-----------------------------------------------------------------------------------------|-------------------|
| name | The name of the pipeline, which will be submitted to the Flink cluster as the job name. | optional | | 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 | | local-time-zone | The local time zone defines current session time zone id. | optional |

@ -42,7 +42,7 @@ public class PipelineOptions {
public static final ConfigOption<Integer> PIPELINE_PARALLELISM = public static final ConfigOption<Integer> PIPELINE_PARALLELISM =
ConfigOptions.key("parallelism") ConfigOptions.key("parallelism")
.intType() .intType()
.noDefaultValue() .defaultValue(1)
.withDescription("Parallelism of the pipeline"); .withDescription("Parallelism of the pipeline");
public static final ConfigOption<SchemaChangeBehavior> PIPELINE_SCHEMA_CHANGE_BEHAVIOR = public static final ConfigOption<SchemaChangeBehavior> PIPELINE_SCHEMA_CHANGE_BEHAVIOR =

Loading…
Cancel
Save