From d95e07d69ec781883f3b5f7fb511cc2e31fdddcf Mon Sep 17 00:00:00 2001 From: "854194341@qq.com" Date: Sat, 17 Sep 2022 14:42:16 +0800 Subject: [PATCH] Add test for HUDI-4780 --- .../hudi/common/functional/TestHoodieLogFormat.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/hudi-common/src/test/java/org/apache/hudi/common/functional/TestHoodieLogFormat.java b/hudi-common/src/test/java/org/apache/hudi/common/functional/TestHoodieLogFormat.java index 4fa53bb41f9f8..1bdd297ea21a7 100755 --- a/hudi-common/src/test/java/org/apache/hudi/common/functional/TestHoodieLogFormat.java +++ b/hudi-common/src/test/java/org/apache/hudi/common/functional/TestHoodieLogFormat.java @@ -26,6 +26,7 @@ import org.apache.hudi.common.model.HoodieLogFile; import org.apache.hudi.common.model.HoodieRecord; import org.apache.hudi.common.model.HoodieTableType; +import org.apache.hudi.common.table.HoodieTableMetaClient; import org.apache.hudi.common.table.log.AppendResult; import org.apache.hudi.common.table.log.HoodieLogFileReader; import org.apache.hudi.common.table.log.HoodieLogFormat; @@ -124,12 +125,13 @@ public static void tearDownClass() { @BeforeEach public void setUp() throws IOException, InterruptedException { - this.fs = MiniClusterUtil.fileSystem; + FileSystem fileSystemOriginal = MiniClusterUtil.fileSystem; - assertTrue(fs.mkdirs(new Path(tempDir.toAbsolutePath().toString()))); + assertTrue(fileSystemOriginal.mkdirs(new Path(tempDir.toAbsolutePath().toString()))); this.partitionPath = new Path(tempDir.toAbsolutePath().toString()); this.basePath = tempDir.getParent().toString(); - HoodieTestUtils.init(MiniClusterUtil.configuration, basePath, HoodieTableType.MERGE_ON_READ); + HoodieTableMetaClient init = HoodieTestUtils.init(MiniClusterUtil.configuration, basePath, HoodieTableType.MERGE_ON_READ); + this.fs = init.getFs(); } @AfterEach