shaohui hong created FLINK-36777:
------------------------------------
Summary: The implementation of getting chunk key column in
ChunkUtils.java is weired
Key: FLINK-36777
URL: https://issues.apache.org/jira/browse/FLINK-36777
Project: Flink
Issue Type: Bug
Components: Flink CDC
Affects Versions: 3.0.0
Reporter: shaohui hong
Attachments: getChunkKey.jpg
If a user configure OracleIncrementalSOurce to capture more than one table, and
only set one chunk key column, the function named getChunkKeyColumn defined in
ChunkUtils.java whill throw a ValidationException.
I propose a new implementation of getting chunk key column, the process of
which is shown in the attachment.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
