This is an automated email from the ASF dual-hosted git repository.

shenghang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new e451e5115a [Fix][engine-server] clean BaseServletTest unit case logs 
dir (#9795)
e451e5115a is described below

commit e451e5115a8fada989c56f7bedd998e106362caa
Author: liucongjy <[email protected]>
AuthorDate: Mon Sep 15 10:47:54 2025 +0800

    [Fix][engine-server] clean BaseServletTest unit case logs dir (#9795)
---
 .../seatunnel/engine/server/AbstractSeaTunnelServerTest.java | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git 
a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/AbstractSeaTunnelServerTest.java
 
b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/AbstractSeaTunnelServerTest.java
index 0805d974c8..f65d1fc7c6 100644
--- 
a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/AbstractSeaTunnelServerTest.java
+++ 
b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/AbstractSeaTunnelServerTest.java
@@ -18,6 +18,7 @@
 package org.apache.seatunnel.engine.server;
 
 import org.apache.seatunnel.common.utils.ExceptionUtils;
+import org.apache.seatunnel.common.utils.FileUtils;
 import org.apache.seatunnel.engine.common.config.ConfigProvider;
 import org.apache.seatunnel.engine.common.config.SeaTunnelConfig;
 import org.apache.seatunnel.engine.common.runtime.ExecutionMode;
@@ -25,6 +26,9 @@ import 
org.apache.seatunnel.engine.common.utils.PassiveCompletableFuture;
 import org.apache.seatunnel.engine.core.dag.logical.LogicalDag;
 import org.apache.seatunnel.engine.core.job.JobImmutableInformation;
 
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.core.LoggerContext;
+
 import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.TestInstance;
@@ -36,6 +40,8 @@ import com.hazelcast.logging.ILogger;
 import com.hazelcast.spi.impl.NodeEngine;
 import lombok.extern.slf4j.Slf4j;
 
+import java.nio.file.Path;
+import java.nio.file.Paths;
 import java.util.Collections;
 
 @Slf4j
@@ -128,6 +134,12 @@ public abstract class AbstractSeaTunnelServerTest<T 
extends AbstractSeaTunnelSer
             if (instance != null) {
                 instance.shutdown();
             }
+
+            // Manually release log4j2 context references, otherwise deleting 
log files will fail
+            LoggerContext context = (LoggerContext) 
LogManager.getContext(false);
+            context.close();
+            Path logPath = Paths.get("logs");
+            FileUtils.deleteFile(logPath.toString());
         } catch (Exception e) {
             log.error(ExceptionUtils.getMessage(e));
         }

Reply via email to