DBZ-4321 More testing

debezium · Dec 13, 2023 · 31cdd10 · 31cdd10
1 parent c104829
commit 31cdd10
Showing 1 changed file with 13 additions and 1 deletion.
diff --git a/src/test/java/io/debezium/connector/informix/InformixReselectColumnsProcessorIT.java b/src/test/java/io/debezium/connector/informix/InformixReselectColumnsProcessorIT.java
@@ -5,6 +5,8 @@
  */
 package io.debezium.connector.informix;
 
+import java.util.concurrent.TimeUnit;
+
 import org.junit.After;
 import org.junit.Before;
 
@@ -105,16 +107,26 @@ protected String getInsertWithNullValue() {
 
  @Override
  protected void waitForStreamingStarted() throws InterruptedException {
+ waitForSnapshotToBeCompleted(TestHelper.TEST_CONNECTOR, TestHelper.TEST_DATABASE);
+ // consumeRecordsByTopic(0);
  waitForStreamingRunning(TestHelper.TEST_CONNECTOR, TestHelper.TEST_DATABASE);
  }
 
  private void setRecordsWaitTimeAfterNulls() {
- System.setProperty(RECORDS_WAITTIME_AFTER_NULLS, System.getProperty(RECORDS_WAITTIME_AFTER_NULLS, "120"));
+ // System.setProperty(RECORDS_WAITTIME_AFTER_NULLS, System.getProperty(RECORDS_WAITTIME_AFTER_NULLS, "120"));
  }
 
  protected SourceRecords consumeRecordsByTopicReselectWhenNullStreaming() throws InterruptedException {
+ waitForAvailableRecords(10, TimeUnit.SECONDS);
  SourceRecords records = super.consumeRecordsByTopicReselectWhenNullStreaming();
  records.allRecordsInOrder().forEach(System.out::println);
  return records;
  }
+
+ protected SourceRecords consumeRecordsByTopicReselectWhenNotNullStreaming() throws InterruptedException {
+ waitForAvailableRecords(10, TimeUnit.SECONDS);
+ SourceRecords records = super.consumeRecordsByTopicReselectWhenNotNullStreaming();
+ records.allRecordsInOrder().forEach(System.out::println);
+ return records;
+ }
 }