(fluss) branch main updated: [test] Delete temp dir after cluster shutdown in FlussClusterExtension (#3411)

[yuxia]

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

luoyuxia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new b7338ddc3 [test] Delete temp dir after cluster shutdown in 
FlussClusterExtension (#3411)
b7338ddc3 is described below

commit b7338ddc3ee00a2d53d02e409c1db582de3af995
Author: Dream95 <864197...@qq.com>
AuthorDate: Wed Jun 10 10:41:30 2026 +0800

    [test] Delete temp dir after cluster shutdown in FlussClusterExtension 
(#3411)
---
 .../org/apache/fluss/server/testutils/FlussClusterExtension.java | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git 
a/fluss-server/src/test/java/org/apache/fluss/server/testutils/FlussClusterExtension.java
 
b/fluss-server/src/test/java/org/apache/fluss/server/testutils/FlussClusterExtension.java
index 48777a6f2..3d47a8861 100644
--- 
a/fluss-server/src/test/java/org/apache/fluss/server/testutils/FlussClusterExtension.java
+++ 
b/fluss-server/src/test/java/org/apache/fluss/server/testutils/FlussClusterExtension.java
@@ -68,6 +68,7 @@ import org.apache.fluss.server.zk.data.PartitionRegistration;
 import org.apache.fluss.server.zk.data.RemoteLogManifestHandle;
 import org.apache.fluss.server.zk.data.TableAssignment;
 import org.apache.fluss.server.zk.data.TableRegistration;
+import org.apache.fluss.utils.FileUtils;
 import org.apache.fluss.utils.clock.Clock;
 import org.apache.fluss.utils.clock.SystemClock;
 
@@ -237,10 +238,6 @@ public final class FlussClusterExtension
             rpcClient.close();
             rpcClient = null;
         }
-        if (tempDir != null) {
-            tempDir.delete();
-            tempDir = null;
-        }
         for (TabletServer tabletServer : tabletServers.values()) {
             tabletServer.close();
         }
@@ -258,6 +255,10 @@ public final class FlussClusterExtension
             zooKeeperServer.close();
             zooKeeperServer = null;
         }
+        if (tempDir != null) {
+            FileUtils.deleteDirectoryQuietly(tempDir);
+            tempDir = null;
+        }
     }
 
     /** Start a coordinator server. start a new one if no coordinator server 
exists. */