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/incubator-paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 07d87bce0 [core] Fix warehouse path bug for JdbcCatalog
07d87bce0 is described below
commit 07d87bce05d042c9fc1a045f7c3fb2c0babf2c48
Author: Jingsong <[email protected]>
AuthorDate: Fri Mar 8 11:17:24 2024 +0800
[core] Fix warehouse path bug for JdbcCatalog
---
.../src/main/java/org/apache/paimon/jdbc/JdbcCatalogFactory.java | 2 +-
.../src/test/java/org/apache/paimon/jdbc/JdbcCatalogTest.java | 9 +++++----
2 files changed, 6 insertions(+), 5 deletions(-)
diff --git
a/paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalogFactory.java
b/paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalogFactory.java
index 1c791eb5e..ff438a8c8 100644
--- a/paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalogFactory.java
+++ b/paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalogFactory.java
@@ -37,6 +37,6 @@ public class JdbcCatalogFactory implements CatalogFactory {
@Override
public Catalog create(FileIO fileIO, Path warehouse, CatalogContext
context) {
String catalogKey =
context.options().get(JdbcCatalogOptions.CATALOG_KEY);
- return new JdbcCatalog(fileIO, catalogKey, context.options().toMap(),
warehouse.getName());
+ return new JdbcCatalog(fileIO, catalogKey, context.options().toMap(),
warehouse.toString());
}
}
diff --git
a/paimon-core/src/test/java/org/apache/paimon/jdbc/JdbcCatalogTest.java
b/paimon-core/src/test/java/org/apache/paimon/jdbc/JdbcCatalogTest.java
index a9a225cf1..5cc79fc85 100644
--- a/paimon-core/src/test/java/org/apache/paimon/jdbc/JdbcCatalogTest.java
+++ b/paimon-core/src/test/java/org/apache/paimon/jdbc/JdbcCatalogTest.java
@@ -42,10 +42,10 @@ public class JdbcCatalogTest extends CatalogTestBase {
@BeforeEach
public void setUp() throws Exception {
super.setUp();
- catalog = initCatalog("test-jdbc-catalog", Maps.newHashMap());
+ catalog = initCatalog(Maps.newHashMap());
}
- private JdbcCatalog initCatalog(String storeKey, Map<String, String>
props) {
+ private JdbcCatalog initCatalog(Map<String, String> props) {
Map<String, String> properties = Maps.newHashMap();
properties.put(
CatalogOptions.URI.key(),
@@ -56,8 +56,9 @@ public class JdbcCatalogTest extends CatalogTestBase {
properties.put(CatalogOptions.WAREHOUSE.key(), warehouse);
properties.put(CatalogOptions.LOCK_ENABLED.key(), "true");
properties.putAll(props);
- JdbcCatalog jdbcCatalog = new JdbcCatalog(fileIO, storeKey,
properties, warehouse);
- return jdbcCatalog;
+ JdbcCatalog catalog = new JdbcCatalog(fileIO, "test-jdbc-catalog",
properties, warehouse);
+ assertThat(catalog.warehouse()).isEqualTo(warehouse);
+ return catalog;
}
@Test
