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();