From c52ffe2fcd58d606b9a74486ef10e1b75a7303ac Mon Sep 17 00:00:00 2001
From: Vojtech Juranek <vjuranek@redhat.com>
Date: Tue, 31 Jan 2023 00:11:25 +0100
Subject: [PATCH] DBZ-6035 Await transactions also in
 IncrementalSnapshotWithRecompileIT

Override no-op waitForCdcTransactionPropagation() also in
IncrementalSnapshotWithRecompileIT which also fails very often.
---
 .../sqlserver/IncrementalSnapshotWithRecompileIT.java        | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/IncrementalSnapshotWithRecompileIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/IncrementalSnapshotWithRecompileIT.java
index a76b7983e..bd801a486 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/IncrementalSnapshotWithRecompileIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/IncrementalSnapshotWithRecompileIT.java
@@ -121,4 +121,9 @@ protected Builder mutableConfig(boolean signalTableOnly, boolean storeOnlyCaptur
                 .with(SqlServerConnectorConfig.TABLE_INCLUDE_LIST, tableIncludeList)
                 .with(SchemaHistory.STORE_ONLY_CAPTURED_TABLES_DDL, storeOnlyCapturedDdl);
     }
+
+    @Override
+    protected void waitForCdcTransactionPropagation(int expectedTransactions) throws Exception {
+        TestHelper.waitForCdcTransactionPropagation(connection, TestHelper.TEST_DATABASE_1, expectedTransactions);
+    }
 }