* Add longer wait periods between each test step to avoid race condit…

…ion on GHA.
k8ssandra · Jul 18, 2022 · 0452b16 · 0452b16
1 parent fa074a4
commit 0452b16
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/pulsar-cdc-testutil/app/src/main/scala/io/k8ssandra/pulsarcdctestutil/DataTester.scala b/pulsar-cdc-testutil/app/src/main/scala/io/k8ssandra/pulsarcdctestutil/DataTester.scala
@@ -38,8 +38,8 @@ class DataTester(cassandraOrchestrator: CassandraOrchestrator, pulsarOrchestrato
       res.left.map(m => logger.error(s"Failed to create Cassandra schema: ${m.getMessage}"))
       return res.left.toOption
     }
-    logger.info("Waiting 20 seconds....")
-    Thread.sleep(2000)
+    logger.info("Waiting 2 minutes....")
+    Thread.sleep(12000)
 
    // Configure Pulsar connector.
     res = pulsarOrchestrator.connectorConfigure(
@@ -52,17 +52,17 @@ class DataTester(cassandraOrchestrator: CassandraOrchestrator, pulsarOrchestrato
       res.left.map(m => logger.error(s"Failed to configure Pulsar connector: ${m.getMessage}"))
       return res.left.toOption
     }
-    logger.info("Waiting 20 seconds....")
-    Thread.sleep(2000)
+    logger.info("Waiting 2 minutes....")
+    Thread.sleep(12000)
 
    // Add data to Cassandra
     res = cassandraOrchestrator.addData(cassDCName, cqlStatements)
     if (res.isLeft) {
       res.left.map(m => logger.error(s"Failed to add data to Cassandra: ${m.getMessage}"))
       return res.left.toOption
     }
-    logger.info("Waiting 20 seconds....")
-    Thread.sleep(2000)
+    logger.info("Waiting 2 minutes....")
+    Thread.sleep(12000)
 
     // Fetch data from Pulsar
     val maybeData = pulsarOrchestrator.fetchData()