fixed

sunxiaojian · Mar 28, 2024 · e1d3e78 · e1d3e78
1 parent 64fcd60
commit e1d3e78
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 9 deletions.
diff --git a/paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalogLockContext.java b/paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalogLockContext.java
@@ -19,17 +19,10 @@
 package org.apache.paimon.catalog;
 
 import org.apache.paimon.client.ClientPool;
-import org.apache.paimon.options.Options;
 
 /** Abstract context for lock factory to create lock. */
 public abstract class AbstractCatalogLockContext<CP extends ClientPool.ClientPoolImpl>
         implements CatalogLockContext {
 
-    protected final Options options;
-
-    public AbstractCatalogLockContext(Options options) {
-        this.options = options;
-    }
-
     protected abstract CP clientPool();
 }
diff --git a/paimon-core/src/main/java/org/apache/paimon/catalog/CatalogLockContext.java b/paimon-core/src/main/java/org/apache/paimon/catalog/CatalogLockContext.java
@@ -25,6 +25,8 @@
 /** Context for lock factory to create lock. */
 public interface CatalogLockContext extends Serializable {
 
+    String LOCK_CONFIGURATION_PREFIX = "lock.";
+
     Options options();
 
     static CatalogLockContext fromOptions(Options options) {

diff --git a/paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalogLockContext.java b/paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalogLockContext.java
@@ -26,14 +26,20 @@ public class JdbcCatalogLockContext extends AbstractCatalogLockContext<JdbcClien
 
     private JdbcClientPool connections;
     private final String catalogKey;
+    private final Options options;
 
     public JdbcCatalogLockContext(Options options) {
-        super(options);
+        this.options = options;
         this.catalogKey = options.get(JdbcCatalogOptions.CATALOG_KEY);
+        createConnections();
+    }
+
+    private void createConnections() {
+        if (connections == null) {}
     }
 
     JdbcCatalogLockContext(JdbcClientPool connections, String catalogKey, Options options) {
-        super(options);
+        this.options = options;
         this.connections = connections;
         this.catalogKey = catalogKey;
     }