diff --git a/docs/content/overview/cdc-pipeline.md b/docs/content/overview/cdc-pipeline.md index 9dfd10514..d97455476 100644 --- a/docs/content/overview/cdc-pipeline.md +++ b/docs/content/overview/cdc-pipeline.md @@ -97,5 +97,5 @@ For example, we can use this yaml file to define a pipeline: ```yaml pipeline: name: mysql-to-kafka-pipeline - pipeline.global.parallelism: 1 + parallelism: 1 ``` diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/resources/pipeline-test.yaml b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/resources/pipeline-test.yaml index dc94f571d..52d6aad4f 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/resources/pipeline-test.yaml +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/resources/pipeline-test.yaml @@ -26,4 +26,4 @@ sink: name: Values Sink pipeline: - pipeline.global.parallelism: 1 \ No newline at end of file + parallelism: 1 \ No newline at end of file