Yanquan Lv created FLINK-38723:
----------------------------------
Summary: Provide Flink Configuration in the Context when Building
DataSink/DataSource
Key: FLINK-38723
URL: https://issues.apache.org/jira/browse/FLINK-38723
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Affects Versions: cdc-3.6.0
Reporter: Yanquan Lv
In the Flink RuntimeContext when building a DynamicTable, the Flink
Configuration is already provided to supply additional configuration parameters
in
[Context|https://github.com/apache/flink/blob/667cacc0ef011e7170fb5cc67097c5629de6682b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/DynamicTableFactory.java#L162].
Similarly, when constructing DataSink/DataSource in FlinkCDC, the Flink
Configuration should also be provided to maintain consistency in design
patterns.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)