You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "shaohui hong (Jira)" <ji...@apache.org> on 2024/11/22 10:03:00 UTC

[jira] [Created] (FLINK-36777) The implementation of getting chunk key column in ChunkUtils.java is weired

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)