fix

luoyuxia · luoyuxia · commit 711f7fed17ea · 2024-12-02T14:19:43.000+08:00
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
@@ -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();
         }
     }

Original file line number	Diff line number	Diff line change
`@@ -69,9 +69,7 @@ static void createHDFS(@TempDir File tmp) throws Exception {`
`69`	`69`	`@AfterAll`
`70`	`70`	`static void destroyHDFS() throws Exception {`
`71`	`71`	`if (hdfsCluster != null) {`
`72`		`- hdfsCluster`
`73`		`- .getFileSystem()`
`74`		`- .delete(new org.apache.hadoop.fs.Path(basePath.toUri()), true);`
	`72`	`+ fs.delete(basePath, true);`
`75`	`73`	`hdfsCluster.shutdown();`
`76`	`74`	`}`
`77`	`75`	`}`