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)
