[Test] Use shorter timeout in ClientErrorsTest (#13177)

apache · Dec 8, 2021 · 01d73aa · 01d73aa
1 parent 42469de
commit 01d73aa
Showing 1 changed file with 2 additions and 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
@@ -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) -> {