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));
}