From ab05789a1c98217b8cabac3d59768f8d74d21377 Mon Sep 17 00:00:00 2001
From: Chris Cranford <chris@hibernate.org>
Date: Tue, 3 Sep 2024 02:35:09 -0400
Subject: [PATCH] DBZ-8197 Increase wait time for XStream

---
 .../java/io/debezium/connector/oracle/OracleConnectorIT.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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();