flink-cdc icon indicating copy to clipboard operation
flink-cdc copied to clipboard

[FLINK-36581][cli] Allow passing Flink configuration by yaml job file

Open MOBIN-F opened this issue 11 months ago • 10 comments

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

MOBIN-F avatar Feb 12 '25 03:02 MOBIN-F

@lvyanquan @yuxiqian PTAL~

MOBIN-F avatar Feb 14 '25 05:02 MOBIN-F

Could you clarify the configuration priority hierarchy here?

joyCurry30 avatar Mar 26 '25 06:03 joyCurry30

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.

lvyanquan avatar Mar 26 '25 07:03 lvyanquan

Please help review again @lvyanquan @joyCurry30

MOBIN-F avatar Mar 31 '25 10:03 MOBIN-F

Do we have plans to merge this PR in 3.4? I want to merge this PR in 3.4, WDYT?@lvyanquan

MOBIN-F avatar Apr 23 '25 01:04 MOBIN-F

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.

github-actions[bot] avatar Aug 22 '25 00:08 github-actions[bot]

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.

github-actions[bot] avatar Oct 22 '25 00:10 github-actions[bot]

@MOBIN-F Would you like to continue working on this PR?

yuxiqian avatar Oct 29 '25 09:10 yuxiqian

@MOBIN-F Would you like to continue working on this PR?

yes,I will finish the remaining work next week~

MOBIN-F avatar Oct 29 '25 10:10 MOBIN-F