twalthr commented on code in PR #20840:
URL: https://github.com/apache/flink/pull/20840#discussion_r976274693
##########
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java:
##########
@@ -52,6 +52,15 @@
@Public
public class CheckpointConfig implements java.io.Serializable {
+ // NOTE TO IMPLEMENTERS:
+ // Please do not add further fields to this class. Use the ConfigOption
stack instead!
+ // It is currently very tricky to keep this kind of POJO classes in sync
with instances of
+ // org.apache.flink.configuration.Configuration. Instances of
Configuration are way easier to
+ // pass, layer, merge, restrict, copy, filter, etc.
+ // See ExecutionOptions.RUNTIME_MODE for a reference implementation. If
the option is very
+ // crucial for the API, we can add a dedicated setter to
StreamExecutionEnvironment. Otherwise,
+ // introducing a ConfigOption should be enough.
Review Comment:
Created https://issues.apache.org/jira/browse/FLINK-29379
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
