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)

Reply via email to