You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by vj...@apache.org on 2024/07/20 01:00:55 UTC
(hbase) branch branch-2 updated: HBASE-28745 : Default Zookeeper ConnectionRegistry APIs timeout should be less (#6104) (#6105)
This is an automated email from the ASF dual-hosted git repository.
vjasani pushed a commit to branch branch-2
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2 by this push:
new bd00e6939c8 HBASE-28745 : Default Zookeeper ConnectionRegistry APIs timeout should be less (#6104) (#6105)
bd00e6939c8 is described below
commit bd00e6939c86da6a90c949b02bdef5003fed72bf
Author: Divneet18 <di...@salesforce.com>
AuthorDate: Fri Jul 19 18:00:49 2024 -0700
HBASE-28745 : Default Zookeeper ConnectionRegistry APIs timeout should be less (#6104) (#6105)
Signed-off-by: Viraj Jasani <vj...@apache.org>
---
.../java/org/apache/hadoop/hbase/client/ZKConnectionRegistry.java | 2 +-
.../org/apache/hadoop/hbase/zookeeper/TestReadOnlyZKClient.java | 6 +++---
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ZKConnectionRegistry.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ZKConnectionRegistry.java
index e356b095e24..ae2b657b2bf 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ZKConnectionRegistry.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ZKConnectionRegistry.java
@@ -75,7 +75,7 @@ class ZKConnectionRegistry implements ConnectionRegistry {
private final Configuration conf;
private final int zkRegistryAsyncTimeout;
public static final String ZK_REGISTRY_ASYNC_GET_TIMEOUT = "zookeeper.registry.async.get.timeout";
- public static final int DEFAULT_ZK_REGISTRY_ASYNC_GET_TIMEOUT = 60000; // 1 min
+ public static final int DEFAULT_ZK_REGISTRY_ASYNC_GET_TIMEOUT = 10000; // 10 sec
// User not used, but for rpc based registry we need it
ZKConnectionRegistry(Configuration conf, User ignored) {
diff --git a/hbase-zookeeper/src/test/java/org/apache/hadoop/hbase/zookeeper/TestReadOnlyZKClient.java b/hbase-zookeeper/src/test/java/org/apache/hadoop/hbase/zookeeper/TestReadOnlyZKClient.java
index bd835df4fc5..5f423c5be61 100644
--- a/hbase-zookeeper/src/test/java/org/apache/hadoop/hbase/zookeeper/TestReadOnlyZKClient.java
+++ b/hbase-zookeeper/src/test/java/org/apache/hadoop/hbase/zookeeper/TestReadOnlyZKClient.java
@@ -217,9 +217,9 @@ public class TestReadOnlyZKClient {
@Test
public void testReadWithTimeout() throws Exception {
- assertArrayEquals(DATA, RO_ZK.get(PATH, 60000).get());
- assertEquals(CHILDREN, RO_ZK.exists(PATH, 60000).get().getNumChildren());
- List<String> children = RO_ZK.list(PATH, 60000).get();
+ assertArrayEquals(DATA, RO_ZK.get(PATH, 10000).get());
+ assertEquals(CHILDREN, RO_ZK.exists(PATH, 10000).get().getNumChildren());
+ List<String> children = RO_ZK.list(PATH, 10000).get();
assertEquals(CHILDREN, children.size());
Collections.sort(children);
for (int i = 0; i < CHILDREN; i++) {