This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 32b8f936f0 [test] Local tests exceptionally no write permission when 
creating Hive catalog (#5615)
32b8f936f0 is described below

commit 32b8f936f0ae7a02bdeb9925255ca9a197205dc2
Author: Kerwin <[email protected]>
AuthorDate: Fri May 16 19:53:55 2025 +0800

    [test] Local tests exceptionally no write permission when creating Hive 
catalog (#5615)
---
 .../test/java/org/apache/paimon/hive/FlinkGenericCatalogITCase.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/paimon-hive/paimon-hive-connector-common/src/test/java/org/apache/paimon/hive/FlinkGenericCatalogITCase.java
 
b/paimon-hive/paimon-hive-connector-common/src/test/java/org/apache/paimon/hive/FlinkGenericCatalogITCase.java
index 8507c4c21a..b82c5e579c 100644
--- 
a/paimon-hive/paimon-hive-connector-common/src/test/java/org/apache/paimon/hive/FlinkGenericCatalogITCase.java
+++ 
b/paimon-hive/paimon-hive-connector-common/src/test/java/org/apache/paimon/hive/FlinkGenericCatalogITCase.java
@@ -44,7 +44,7 @@ import org.junit.Test;
 import org.junit.rules.TemporaryFolder;
 import org.junit.runner.RunWith;
 
-import java.util.HashMap;
+import java.util.Collections;
 import java.util.List;
 
 import static org.assertj.core.api.Assertions.assertThat;
@@ -56,6 +56,7 @@ public class FlinkGenericCatalogITCase extends 
AbstractTestBaseJUnit4 {
 
     @Rule public TemporaryFolder folder = new TemporaryFolder();
 
+    protected String path;
     protected TableEnvironment tEnv;
 
     @HiveSQL(files = {})
@@ -70,6 +71,7 @@ public class FlinkGenericCatalogITCase extends 
AbstractTestBaseJUnit4 {
 
     @Before
     public void before() throws Exception {
+        path = folder.newFolder().toURI().toString();
         hiveShell.execute("CREATE DATABASE IF NOT EXISTS test_db");
         hiveShell.execute("USE test_db");
         hiveShell.execute("CREATE TABLE hive_table ( a INT, b STRING )");
@@ -81,7 +83,7 @@ public class FlinkGenericCatalogITCase extends 
AbstractTestBaseJUnit4 {
         FlinkGenericCatalog catalog =
                 FlinkGenericCatalogFactory.createCatalog(
                         this.getClass().getClassLoader(),
-                        new HashMap<>(),
+                        Collections.singletonMap("warehouse", path),
                         hiveCatalog.getName(),
                         hiveCatalog);
         catalog.open();

Reply via email to