suhwan-cheon opened a new pull request, #4117: URL: https://github.com/apache/flink-cdc/pull/4117
issue: https://issues.apache.org/jira/browse/FLINK-38247 ### Issue An infinite loop occurred when using the **MySqlChunkSplitter** to split a table with a **MySQL BIGINT UNSIGNED primary key**. (This problem happens when the primary key value exceeds Long.MAX_VALUE) --- ### Solution The new **`StatementUtils.setSafeObject`** method was introduced to fix this issue. It detects the overflow and correctly converts the value to a **`BigDecimal`** before setting it in the `PreparedStatement`. --- ### Verification * A new unit test, **`StatementUtilsTest`**, was added to verify the correctness of `StatementUtils.setSafeObject`. * Java's **dynamic proxy** (`createPreparedStatementProxy`) was used to avoid creating a verbose mock class, simplifying the test code. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
