diff --git a/flink-cdc-cli/src/main/java/com/ververica/cdc/cli/parser/YamlPipelineDefinitionParser.java b/flink-cdc-cli/src/main/java/com/ververica/cdc/cli/parser/YamlPipelineDefinitionParser.java index 1ae0153e00..ecf60f9cbe 100644 --- a/flink-cdc-cli/src/main/java/com/ververica/cdc/cli/parser/YamlPipelineDefinitionParser.java +++ b/flink-cdc-cli/src/main/java/com/ververica/cdc/cli/parser/YamlPipelineDefinitionParser.java @@ -49,8 +49,8 @@ public class YamlPipelineDefinitionParser implements PipelineDefinitionParser { private static final String NAME_KEY = "name"; // Route keys - private static final String ROUTE_SOURCE_TABLE_KEY = "sourceTable"; - private static final String ROUTE_SINK_TABLE_KEY = "sinkTable"; + private static final String ROUTE_SOURCE_TABLE_KEY = "source-table"; + private static final String ROUTE_SINK_TABLE_KEY = "sink-table"; private static final String ROUTE_DESCRIPTION_KEY = "description"; private final ObjectMapper mapper = new ObjectMapper(new YAMLFactory()); diff --git a/flink-cdc-cli/src/test/resources/definitions/pipeline-definition-full.yaml b/flink-cdc-cli/src/test/resources/definitions/pipeline-definition-full.yaml index 07b7e5c834..a719b45fff 100644 --- a/flink-cdc-cli/src/test/resources/definitions/pipeline-definition-full.yaml +++ b/flink-cdc-cli/src/test/resources/definitions/pipeline-definition-full.yaml @@ -30,11 +30,11 @@ sink: auto-create-table: true route: - - sourceTable: mydb.default.app_order_.* - sinkTable: odsdb.default.app_order + - source-table: mydb.default.app_order_.* + sink-table: odsdb.default.app_order description: sync all sharding tables to one - - sourceTable: mydb.default.web_order - sinkTable: odsdb.default.ods_web_order + - source-table: mydb.default.web_order + sink-table: odsdb.default.ods_web_order description: sync table to with given prefix ods_ transform: diff --git a/flink-cdc-cli/src/test/resources/definitions/pipeline-definition-with-optional.yaml b/flink-cdc-cli/src/test/resources/definitions/pipeline-definition-with-optional.yaml index aab278a6a0..f721682ac1 100644 --- a/flink-cdc-cli/src/test/resources/definitions/pipeline-definition-with-optional.yaml +++ b/flink-cdc-cli/src/test/resources/definitions/pipeline-definition-with-optional.yaml @@ -25,8 +25,8 @@ sink: bootstrap-servers: localhost:9092 route: - - sourceTable: mydb.default.app_order_.* - sinkTable: odsdb.default.app_order + - source-table: mydb.default.app_order_.* + sink-table: odsdb.default.app_order pipeline: parallelism: 4 diff --git a/flink-cdc-composer/src/main/java/com/ververica/cdc/composer/definition/RouteDef.java b/flink-cdc-composer/src/main/java/com/ververica/cdc/composer/definition/RouteDef.java index 21dfdce55f..32b705ab4e 100644 --- a/flink-cdc-composer/src/main/java/com/ververica/cdc/composer/definition/RouteDef.java +++ b/flink-cdc-composer/src/main/java/com/ververica/cdc/composer/definition/RouteDef.java @@ -27,8 +27,8 @@ *

A router definition contains: * *

*/ @@ -58,9 +58,9 @@ public Optional getDescription() { @Override public String toString() { return "RouteDef{" - + "matcher=" + + "sourceTable=" + sourceTable - + ", replace=" + + ", sinkTable=" + sinkTable + ", description='" + description