From b0a4a8b5ba113a6d2b79ac8e9ba037c45402de1a Mon Sep 17 00:00:00 2001 From: James Gormley Date: Tue, 29 Sep 2020 09:00:01 -0400 Subject: [PATCH] DBZ-2495 Making test slightly more stable --- .../io/debezium/connector/sqlserver/SqlServerConnectorIT.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorIT.java index cc1e7db14..b825782fc 100644 --- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorIT.java +++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorIT.java @@ -1428,6 +1428,7 @@ public void whenCaptureInstanceExcludesColumnsAndColumnsRenamedExpectNoErrors() Arrays.asList("id", "name")); final Configuration config = TestHelper.defaultConfig() + .with(RelationalDatabaseConnectorConfig.TABLE_INCLUDE_LIST, ".*excluded_column_table_a") .build(); start(SqlServerConnector.class, config); @@ -1443,7 +1444,7 @@ public void whenCaptureInstanceExcludesColumnsAndColumnsRenamedExpectNoErrors() connection.execute("INSERT INTO excluded_column_table_a VALUES(11, 'some_name', 120)"); - final SourceRecords records = consumeRecordsByTopic(3); + final SourceRecords records = consumeRecordsByTopic(2); final List tableA = records.recordsForTopic("server1.dbo.excluded_column_table_a"); Schema expectedSchema1 = SchemaBuilder.struct()