-
Notifications
You must be signed in to change notification settings - Fork 1.9k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[FLINK-36174][hotfix] CDC yaml without pipeline should not throw exception. #3588
base: master
Are you sure you want to change the base?
Conversation
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/YamlPipelineDefinitionParser.java
Show resolved
Hide resolved
@yuxiqian , CC |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Should private final PipelineDef minimizedDef
field be updated to reflect this change?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Test YamlPipelineDefinitionParserTest.YamlPipelineDefinitionParserTest will do it.
Configuration.fromMap( | ||
Collections.singletonMap( | ||
"local-time-zone", ZoneId.systemDefault().toString()))); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Seems it's not necessary to pass local-time-zone
explicitly since it will be added when constructing PipelineDef
anyway
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM.
CDC yaml without pipeline should not throw exception.