From 4c59fcb2404dd4875a74f61c11b2c33f61ebef3b Mon Sep 17 00:00:00 2001 From: Masahiro Sakamoto Date: Thu, 25 Jul 2019 16:04:44 +0900 Subject: [PATCH] Topic loading in rest-api should time out in zooKeeperOperationTimeoutSeconds --- .../apache/pulsar/broker/admin/impl/PersistentTopicsBase.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java index 8c51b0379b62b..4c06610dbb423 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java @@ -1343,7 +1343,7 @@ public static CompletableFuture getPartitionedTopicMet private Topic getTopicReference(TopicName topicName) { try { return pulsar().getBrokerService().getTopicIfExists(topicName.toString()) - .get(pulsar().getConfiguration().getZooKeeperSessionTimeoutMillis(), TimeUnit.MILLISECONDS) + .get(pulsar().getConfiguration().getZooKeeperOperationTimeoutSeconds(), TimeUnit.SECONDS) .orElseThrow(() -> topicNotFoundReason(topicName)); } catch (RestException e) { throw e;