From 01d73aa90a4dd13f6b4306ef8e52e1dce7ee401d Mon Sep 17 00:00:00 2001 From: Michael Marshall Date: Tue, 7 Dec 2021 18:22:58 -0600 Subject: [PATCH] [Test] Use shorter timeout in ClientErrorsTest (#13177) --- .../java/org/apache/pulsar/client/api/ClientErrorsTest.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ClientErrorsTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ClientErrorsTest.java index f66b19808f564..5b2bf4eecadd8 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ClientErrorsTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ClientErrorsTest.java @@ -327,7 +327,8 @@ public void testLookupWithDisconnection() throws Exception { private void subscribeFailWithoutRetry(String topic) throws Exception { @Cleanup - PulsarClient client = PulsarClient.builder().serviceUrl(mockBrokerService.getBrokerAddress()).build(); + PulsarClient client = PulsarClient.builder().serviceUrl(mockBrokerService.getBrokerAddress()) + .operationTimeout(1, TimeUnit.SECONDS).build(); final AtomicInteger counter = new AtomicInteger(0); mockBrokerService.setHandleSubscribe((ctx, subscribe) -> {