Robin Moffatt created FLINK-36829: ------------------------------------- Summary: Add better validation of pipeline config Key: FLINK-36829 URL: https://issues.apache.org/jira/browse/FLINK-36829 Project: Flink Issue Type: Improvement Components: Flink CDC Reporter: Robin Moffatt
If the `pipeline` section is missing then the user just gets a NullPointerException error: {code:java} ❯ bin/flink-cdc.sh mysql-to-doris.yaml Exception in thread "main" java.lang.NullPointerException at org.apache.flink.cdc.cli.parser.YamlPipelineDefinitionParser.parse(YamlPipelineDefinitionParser.java:110) at org.apache.flink.cdc.cli.parser.YamlPipelineDefinitionParser.parse(YamlPipelineDefinitionParser.java:95) at org.apache.flink.cdc.cli.CliExecutor.run(CliExecutor.java:85) at org.apache.flink.cdc.cli.CliFrontend.main(CliFrontend.java:69){code} It would be good if Flink CDC validated the YAML config and instead reported to the user e.g. "Pipeline YAML is not valid. `pipeline` section is missing". -- This message was sent by Atlassian Jira (v8.20.10#820010)