diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorIT.java index ac1f7e98b..3b710f00c 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorIT.java +++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorIT.java @@ -4457,10 +4457,13 @@ public void shouldGracefullySkipObjectBasedTables() throws Exception { .with(OracleConnectorConfig.TABLE_INCLUDE_LIST, "DEBEZIUM\\.DBZ5441") .build(); + int waitTime = TestHelper.defaultMessageConsumerPollTimeout() * 2; + final LogInterceptor streamInterceptor; switch (TestHelper.getAdapter(config)) { case XSTREAM: streamInterceptor = new LogInterceptor("io.debezium.connector.oracle.xstream.LcrEventHandler"); + waitTime *= 2; // XStream on CI can be quite slow, double the wait time to avoid failure break; default: streamInterceptor = new LogInterceptor(AbstractLogMinerEventProcessor.class); @@ -4479,7 +4482,7 @@ public void shouldGracefullySkipObjectBasedTables() throws Exception { connection.execute("INSERT INTO DEBEZIUM.DBZ5441 (id,lvl) values (1,1)"); Awaitility.await() - .atMost(180, TimeUnit.SECONDS) + .atMost(waitTime, TimeUnit.SECONDS) .until(() -> streamInterceptor.containsMessage("is not a relational table and will be skipped")); assertNoRecordsToConsume();