alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-8197 Increase wait time for XStream

Browse Source
This commit is contained in:
Chris Cranford 2024-09-03 02:35:09 -04:00 committed by Chris Cranford
parent 40899c2269
commit ab05789a1c
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorIT.java
View File

@ -4457,10 +4457,13 @@ public void shouldGracefullySkipObjectBasedTables() throws Exception {
.with(OracleConnectorConfig.TABLE_INCLUDE_LIST, "DEBEZIUM\\.DBZ5441") .with(OracleConnectorConfig.TABLE_INCLUDE_LIST, "DEBEZIUM\\.DBZ5441")
.build(); .build();
int waitTime = TestHelper.defaultMessageConsumerPollTimeout() * 2;
final LogInterceptor streamInterceptor; final LogInterceptor streamInterceptor;
switch (TestHelper.getAdapter(config)) { switch (TestHelper.getAdapter(config)) {
case XSTREAM: case XSTREAM:
streamInterceptor = new LogInterceptor("io.debezium.connector.oracle.xstream.LcrEventHandler"); 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; break;
default: default:
streamInterceptor = new LogInterceptor(AbstractLogMinerEventProcessor.class); 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)"); connection.execute("INSERT INTO DEBEZIUM.DBZ5441 (id,lvl) values (1,1)");
Awaitility.await() Awaitility.await()
.atMost(180, TimeUnit.SECONDS) .atMost(waitTime, TimeUnit.SECONDS)
.until(() -> streamInterceptor.containsMessage("is not a relational table and will be skipped")); .until(() -> streamInterceptor.containsMessage("is not a relational table and will be skipped"));
assertNoRecordsToConsume(); assertNoRecordsToConsume();