flink-cdc
flink-cdc copied to clipboard
[FLINK-35633][cli] Verify YAML pipeline definitions early
This closes FLINK-35633.
This requires #3428 being merged first.
Currently, transform & route rules will be passed to Flink operators as strings, and any malformed configurations will not be exposed until runtime, which makes testing and debugging harder.
This PR adds early verification logic in Flink CDC CLI, and tries to provide more clear and descriptive error messages for input YAML files.