minor fixes (#77)

hstreamdb · Aug 6, 2024 · d1877ad · d1877ad
1 parent 88061bb
commit d1877ad
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/app/src/main/scala/hstream/server/KafkaBroker.scala b/app/src/main/scala/hstream/server/KafkaBroker.scala
@@ -81,6 +81,11 @@ object KafkaBroker extends Logging {
     if (configs.isEmpty) {
       throw new RuntimeException("No broker configs found!")
     }
+
+    if (configs.head.testingConfig.isEmpty) {
+      info("No testingConfig found, skip awaitCluster")
+      return
+    }
     val initPort = configs.head.port
     val image = configs.head.testingConfig
       .getOrElse("image", throw new IllegalArgumentException("image is required"))