From 4284d629300703713a1c3f52581db1fe264d69d5 Mon Sep 17 00:00:00 2001 From: mfvitale Date: Thu, 4 Jan 2024 14:06:04 +0100 Subject: [PATCH] DBZ-7311 Permits to execute a blocking snapshot even if snapshot.mode=never --- .../connector/vitess/VitessSnapshotChangeEventSource.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/io/debezium/connector/vitess/VitessSnapshotChangeEventSource.java b/src/main/java/io/debezium/connector/vitess/VitessSnapshotChangeEventSource.java index 4824eed1..9bdb77b4 100644 --- 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 prepare(VitessPartition partition) { - return new RelationalSnapshotContext<>(partition, ""); + protected SnapshotContext prepare(VitessPartition partition, boolean onDemand) { + return new RelationalSnapshotContext<>(partition, "", onDemand); } @Override