fix

JNSimba · Mar 11, 2024 · 8bca31e · 8bca31e
1 parent a758cee
commit 8bca31e
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisTestBase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisTestBase.java
@@ -72,7 +72,10 @@ protected static String getFenodes() {
         return DORIS_CONTAINER.getHost() + ":8030";
     }
 
-    @BeforeClass
+    static {
+        startContainers();
+    }
+
     public static void startContainers() {
         LOG.info("Starting doris containers...");
         Startables.deepStart(Stream.of(DORIS_CONTAINER)).join();
@@ -84,23 +87,22 @@ public static void startContainers() {
         LOG.info("Containers doris are started.");
     }
 
-    @AfterClass
     public static void stopContainers() {
         LOG.info("Stopping doris containers...");
         DORIS_CONTAINER.stop();
         LOG.info("Containers doris are stopped.");
     }
 
     public static GenericContainer createDorisContainer() {
+        LOG.info("Create doris containers...");
         GenericContainer container =
                 new GenericContainer<>(DORIS_DOCKER_IMAGE)
                         .withNetwork(Network.newNetwork())
                         .withNetworkAliases("DorisContainer")
                         .withPrivilegedMode(true)
                         .withLogConsumer(
                                 new Slf4jLogConsumer(
-                                        DockerLoggerFactory.getLogger(DORIS_DOCKER_IMAGE)))
-                        .withReuse(true);
+                                        DockerLoggerFactory.getLogger(DORIS_DOCKER_IMAGE)));
 
         container.setPortBindings(
                 Lists.newArrayList(