(flink-cdc) branch master updated: [Minor][FLINK-39168][cdc-connector-mysql] Cache split.splitId() result in a local variable to avoid calling the method twice per iteration: (#4288)

[kunni]

This is an automated email from the ASF dual-hosted git repository.

kunni pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git


The following commit(s) were added to refs/heads/master by this push:
     new ef9f977e2 [Minor][FLINK-39168][cdc-connector-mysql] Cache 
split.splitId() result in a local variable to avoid calling the method twice 
per iteration: (#4288)
ef9f977e2 is described below

commit ef9f977e2e62b82e560a50d2c57b463538a65088
Author: Thorne <46524102+thorne...@users.noreply.github.com>
AuthorDate: Fri Feb 27 19:48:53 2026 +0800

    [Minor][FLINK-39168][cdc-connector-mysql] Cache split.splitId() result in a 
local variable to avoid calling the method twice per iteration: (#4288)
    
    Co-authored-by: Thorne <syyf...@163.com>
---
 .../mysql/source/assigners/MySqlSnapshotSplitAssigner.java           | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java
 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java
index 1acbeac94..106fc07dd 100644
--- 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java
+++ 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java
@@ -390,11 +390,12 @@ public class MySqlSnapshotSplitAssigner implements 
MySqlSplitAssigner {
                 new ArrayList<>(assignedSplits.values());
         List<FinishedSnapshotSplitInfo> finishedSnapshotSplitInfos = new 
ArrayList<>();
         for (MySqlSchemalessSnapshotSplit split : assignedSnapshotSplit) {
-            BinlogOffset binlogOffset = 
splitFinishedOffsets.get(split.splitId());
+            String splitId = split.splitId();
+            BinlogOffset binlogOffset = splitFinishedOffsets.get(splitId);
             finishedSnapshotSplitInfos.add(
                     new FinishedSnapshotSplitInfo(
                             split.getTableId(),
-                            split.splitId(),
+                            splitId,
                             split.getSplitStart(),
                             split.getSplitEnd(),
                             binlogOffset));