DBZ-7311 Permits to execute a blocking snapshot even if snapshot.mode…

…=never
debezium · Jan 8, 2024 · 4284d62 · 4284d62
1 parent 2282b1b
commit 4284d62
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/io/debezium/connector/vitess/VitessSnapshotChangeEventSource.java b/src/main/java/io/debezium/connector/vitess/VitessSnapshotChangeEventSource.java
@@ -87,8 +87,8 @@ public SnapshottingTask getSnapshottingTask(VitessPartition partition, VitessOff
     }
 
     @Override
-    protected SnapshotContext<VitessPartition, VitessOffsetContext> prepare(VitessPartition partition) {
-        return new RelationalSnapshotContext<>(partition, "");
+    protected SnapshotContext<VitessPartition, VitessOffsetContext> prepare(VitessPartition partition, boolean onDemand) {
+        return new RelationalSnapshotContext<>(partition, "", onDemand);
     }
 
     @Override