fix

apache · Sep 14, 2022 · 29617f5 · 29617f5
1 parent 6665875
commit 29617f5
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/...src/test/java/org/apache/seatunnel/connectors/seatunnel/iceberg/TestIcebergMetastore.java b/...src/test/java/org/apache/seatunnel/connectors/seatunnel/iceberg/TestIcebergMetastore.java
@@ -24,6 +24,9 @@
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+
+import java.io.File;
 
 public class TestIcebergMetastore {
 
@@ -37,11 +40,14 @@ public void start() {
         METASTORE_URI = METASTORE.hiveConf().get(HiveConf.ConfVars.METASTOREURIS.varname);
     }
 
-    // @Test
+    @Test
     public void testUseHiveMetastore() {
+        String warehousePath = "/tmp/seatunnel/iceberg/hive/";
+        new File(warehousePath).mkdirs();
+
         HiveCatalog catalog = (HiveCatalog) new IcebergCatalogFactory("seatunnel",
             "hive",
-            "file:///tmp/seatunnel/iceberg/hive/",
+            "file://" + warehousePath,
             METASTORE_URI)
             .create();
         catalog.createNamespace(Namespace.of("test_database"));