diff --git a/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/TestHiveSyncTool.java b/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/TestHiveSyncTool.java index 7abeed480c639..a5338afbf1eb1 100644 --- a/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/TestHiveSyncTool.java +++ b/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/TestHiveSyncTool.java @@ -107,7 +107,7 @@ private static Iterable syncModeAndSchemaFromCommitMetadata() { private HoodieHiveSyncClient hiveClient; @AfterAll - public static void cleanUpClass() { + public static void cleanUpClass() throws IOException { HiveTestUtil.shutdown(); } diff --git a/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/replication/TestHiveSyncGlobalCommitTool.java b/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/replication/TestHiveSyncGlobalCommitTool.java index 9dffdd0444d94..a11b23762e73a 100644 --- a/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/replication/TestHiveSyncGlobalCommitTool.java +++ b/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/replication/TestHiveSyncGlobalCommitTool.java @@ -24,7 +24,6 @@ import org.apache.hadoop.fs.Path; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeEach; -import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.RegisterExtension; @@ -49,7 +48,6 @@ import static org.junit.jupiter.api.Assertions.assertNotEquals; import static org.junit.jupiter.api.Assertions.assertTrue; -@Disabled public class TestHiveSyncGlobalCommitTool { @RegisterExtension diff --git a/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/testutils/HiveTestUtil.java b/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/testutils/HiveTestUtil.java index 9687e557928bd..71882abb65a5b 100644 --- a/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/testutils/HiveTestUtil.java +++ b/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/testutils/HiveTestUtil.java @@ -141,7 +141,7 @@ public static void setUp() throws IOException, InterruptedException, HiveExcepti hiveSyncProps.setProperty(META_SYNC_PARTITION_FIELDS.key(), "datestr"); hiveSyncProps.setProperty(HIVE_BATCH_SYNC_PARTITION_NUM.key(), "3"); - hiveSyncConfig = new HiveSyncConfig(hiveSyncProps, configuration); + hiveSyncConfig = new HiveSyncConfig(hiveSyncProps, getHiveConf()); dtfOut = DateTimeFormatter.ofPattern("yyyy/MM/dd"); ddlExecutor = new HiveQueryDDLExecutor(hiveSyncConfig); @@ -176,7 +176,7 @@ public static HiveConf getHiveConf() { return hiveServer.getHiveConf(); } - public static void shutdown() { + public static void shutdown() throws IOException { if (hiveServer != null) { hiveServer.stop(); } @@ -186,6 +186,7 @@ public static void shutdown() { if (zkServer != null) { zkServer.shutdown(); } + FileSystem.closeAll(); } public static void createCOWTable(String instantTime, int numberOfPartitions, boolean useSchemaFromCommitMetadata, diff --git a/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/testutils/TestCluster.java b/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/testutils/TestCluster.java index c1f891fce8431..2e8a63cf847b6 100644 --- a/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/testutils/TestCluster.java +++ b/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/testutils/TestCluster.java @@ -18,6 +18,7 @@ package org.apache.hudi.hive.testutils; +import org.apache.hadoop.fs.FileSystem; import org.apache.hudi.avro.HoodieAvroWriteSupport; import org.apache.hudi.common.bloom.BloomFilter; import org.apache.hudi.common.bloom.BloomFilterFactory; @@ -264,10 +265,11 @@ public void startHiveServer2() { } } - public void shutDown() { + public void shutDown() throws IOException { stopHiveServer2(); Hive.closeCurrent(); hiveTestService.getHiveMetaStore().stop(); hdfsTestService.stop(); + FileSystem.closeAll(); } }