diff --git a/fluss-filesystems/fluss-fs-hadoop/src/test/java/com/alibaba/fluss/fs/hdfs/HdfsBehaviorTest.java b/fluss-filesystems/fluss-fs-hadoop/src/test/java/com/alibaba/fluss/fs/hdfs/HdfsBehaviorTest.java index 949825206..508a5340f 100644 --- a/fluss-filesystems/fluss-fs-hadoop/src/test/java/com/alibaba/fluss/fs/hdfs/HdfsBehaviorTest.java +++ b/fluss-filesystems/fluss-fs-hadoop/src/test/java/com/alibaba/fluss/fs/hdfs/HdfsBehaviorTest.java @@ -69,9 +69,7 @@ static void createHDFS(@TempDir File tmp) throws Exception { @AfterAll static void destroyHDFS() throws Exception { if (hdfsCluster != null) { - hdfsCluster - .getFileSystem() - .delete(new org.apache.hadoop.fs.Path(basePath.toUri()), true); + // fs.delete(basePath, true); hdfsCluster.shutdown(); } }