aiwenmo commented on code in PR #3812:
URL: https://github.com/apache/flink-cdc/pull/3812#discussion_r2051478326
##########
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/PipelineOptions.java:
##########
@@ -45,6 +45,12 @@ public class PipelineOptions {
.defaultValue(1)
.withDescription("Parallelism of the pipeline");
+ public static final ConfigOption<RuntimeMode> PIPELINE_RUNTIME_MODE =
Review Comment:
Regarding this issue, there have been numerous exchanges of views and
modifications with other reviewers before. Now, I want to know the following
information more clearly:
1.Should we change to the same parameter definition as that of Flink, with
our parameter having a lower priority than Flink's own parameters?
2.Is it feasible to use "snapshot" along with Flink's own parameters for
control? In this way, when users enable the batch mode, they need to explicitly
specify Flink's `execution.runtime-mode` parameter.
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
