fixed

sunxiaojian · Mar 25, 2024 · 21d6db5 · 21d6db5
1 parent c6bb67d
commit 21d6db5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/paimon-core/src/main/java/org/apache/paimon/catalog/LockContextUtils.java b/paimon-core/src/main/java/org/apache/paimon/catalog/LockContextUtils.java
@@ -50,7 +50,7 @@ public static Optional<CatalogLock.LockContext> lockContext(
                 tryInitializeJdbcConnections(catalogOptions);
                 return Optional.of(
                         new JdbcCatalogLock.JdbcLockContext(
-                                connections, catalogKey, catalogOptions.toMap()));
+                                connections, catalogKey, catalogOptions));
             default:
                 LOG.warn("Unsupported lock type:" + lockType);
                 return Optional.of(new AbstractCatalog.OptionLockContext(catalogOptions));
@@ -66,7 +66,7 @@ private static void tryInitializeJdbcConnections(Options catalogOptions) {
                             catalogOptions.toMap());
             // Check and create distributed lock table.
             try {
-                JdbcUtils.createDistributedLockTable(connections);
+                JdbcUtils.createDistributedLockTable(connections, catalogOptions);
             } catch (SQLException e) {
                 throw new RuntimeException("Cannot initialize JDBC distributed lock.", e);
             } catch (InterruptedException e) {