update

apache · Oct 17, 2024 · b83b2fd · b83b2fd
1 parent 788853d
commit b83b2fd
Showing 1 changed file with 0 additions and 9 deletions.
diff --git a/...ive-jdbc/src/main/java/org/apache/kyuubi/jdbc/hive/strategy/zk/PollingChooseStrategy.java b/...ive-jdbc/src/main/java/org/apache/kyuubi/jdbc/hive/strategy/zk/PollingChooseStrategy.java
@@ -18,13 +18,11 @@
 package org.apache.kyuubi.jdbc.hive.strategy.zk;
 
 import java.util.List;
-import java.util.concurrent.TimeUnit;
 import org.apache.kyuubi.jdbc.hive.ZooKeeperHiveClientException;
 import org.apache.kyuubi.jdbc.hive.strategy.ChooseServerStrategy;
 import org.apache.kyuubi.shaded.curator.framework.CuratorFramework;
 import org.apache.kyuubi.shaded.curator.framework.recipes.atomic.AtomicValue;
 import org.apache.kyuubi.shaded.curator.framework.recipes.atomic.DistributedAtomicInteger;
-import org.apache.kyuubi.shaded.curator.framework.recipes.locks.InterProcessSemaphoreMutex;
 import org.apache.kyuubi.shaded.curator.retry.RetryForever;
 
 public class PollingChooseStrategy implements ChooseServerStrategy {
@@ -40,13 +38,6 @@ public String chooseServer(List<String> serverHosts, CuratorFramework zkClient,
     } catch (Exception e) {
       throw new ZooKeeperHiveClientException(
           "Oops, PollingChooseStrategy get the server is wrong!", e);
-    } finally {
-      try {
-        lock.release();
-      } catch (Exception e) {
-        throw new ZooKeeperHiveClientException(
-            "Oops,PollingChooseStrategy releasing lock is wrong!", e);
-      }
     }
   }