DBZ-4331 Avoid holding metadata lock in R/O incremental snapshots

shichao-an · Nov 30, 2021 · b51a4be · b51a4be
1 parent 2347b58
commit b51a4be
Showing 1 changed file with 2 additions and 8 deletions.
diff --git a/...n/java/io/debezium/connector/mysql/MySqlReadOnlyIncrementalSnapshotChangeEventSource.java b/...n/java/io/debezium/connector/mysql/MySqlReadOnlyIncrementalSnapshotChangeEventSource.java
@@ -177,14 +177,7 @@ public void processTransactionCommittedEvent(Partition partition, OffsetContext
     }
 
     protected void updateLowWatermark() {
-        try {
-            getExecutedGtidSet(getContext()::setLowWatermark);
-            // it is required that the chunk selection sees the changes that are committed before its execution
-            jdbcConnection.commit();
-        }
-        catch (SQLException e) {
-            throw new DebeziumException(e);
-        }
+        getExecutedGtidSet(getContext()::setLowWatermark);
     }
 
     protected void updateHighWatermark() {
@@ -205,6 +198,7 @@ private void getExecutedGtidSet(Consumer<GtidSet> watermark) {
                     }
                 }
             });
+            jdbcConnection.commit();
         }
         catch (SQLException e) {
             throw new DebeziumException(e);