[FLINK-36581][cli] Allow passing Flink configuration by yaml job file
At present, FlinkCDC only supports reading Flink configurations from Flink con files, but this approach is not user-friendly for multiple jobs that require different configurations. Allow passing Flink configuration by yaml job file such as :
source:
type: mysql
...
sink:
type: value
pipeline:
name: MySQL to Kafka Pipeline
parallelism: 1
flink-conf:
execution.checkpointing.interval: 6min
@lvyanquan @yuxiqian PTAL~
Could you clarify the configuration priority hierarchy here?
Could you clarify the configuration priority hierarchy here?
Please add this to document since we can add configuration through config.yaml/flink-cdc.sh/job.yaml.
Please help review again @lvyanquan @joyCurry30
Do we have plans to merge this PR in 3.4? I want to merge this PR in 3.4, WDYT?@lvyanquan
This pull request has been automatically marked as stale because it has not had recent activity for 120 days. It will be closed in 60 days if no further activity occurs.
This pull request has been closed because it has not had recent activity. You could reopen it if you try to continue your work, and anyone who are interested in it are encouraged to continue work on this pull request.
@MOBIN-F Would you like to continue working on this PR?
@MOBIN-F Would you like to continue working on this PR?
yes,I will finish the remaining work next week~