fix CdcToBigQueryChangeApplierPipelineIT debezium wait logic (#1729)

Signed-off-by: Jeffrey Kinard <[email protected]>
GoogleCloudPlatform · Aug 2, 2024 · b4c0c29 · b4c0c29
1 parent f6d2404
commit b4c0c29
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/...test/java/com/google/cloud/dataflow/cdc/applier/CdcToBigQueryChangeApplierPipelineIT.java b/...test/java/com/google/cloud/dataflow/cdc/applier/CdcToBigQueryChangeApplierPipelineIT.java
@@ -223,9 +223,13 @@ private void testDebeziumCdcToBigQuery(boolean singleTopicMode) throws Exception
         LOG.info("Debezium process status: {}", embeddedConnector.isAlive());
 
         if (!embeddedConnector.isAlive()) {
-          throw new IllegalStateException("Debezium hasn't started");
+          TimeUnit.SECONDS.sleep(5);
+        } else {
+          break;
         }
-        TimeUnit.SECONDS.sleep(5);
+      }
+      if (!embeddedConnector.isAlive()) {
+        throw new IllegalStateException("Debezium hasn't started");
       }
       LOG.info("Debezium connector successfully started!");