(pulsar) branch master updated: [improve][client] Ignore InterruptedException when pulsar-perf finishing (#21613)

[tison]

This is an automated email from the ASF dual-hosted git repository.

tison pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 5229a73fea6 [improve][client] Ignore InterruptedException when 
pulsar-perf finishing (#21613)
5229a73fea6 is described below

commit 5229a73fea69c810f1d56ad0589923a6140e1e06
Author: Lishen Yao <yaa...@gmail.com>
AuthorDate: Sat Nov 25 15:58:47 2023 +0800

    [improve][client] Ignore InterruptedException when pulsar-perf finishing 
(#21613)
---
 .../src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java | 2 --
 1 file changed, 2 deletions(-)

diff --git 
a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java
 
b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java
index e57d6ca2251..16a32fe6344 100644
--- 
a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java
+++ 
b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java
@@ -581,7 +581,6 @@ public class PerformanceProducer {
                             log.info("------------- DONE (reached the maximum 
duration: [{} seconds] of production) "
                                     + "--------------", arguments.testTime);
                             doneLatch.countDown();
-                            Thread.sleep(5000);
                             produceEnough = true;
                             break;
                         }
@@ -592,7 +591,6 @@ public class PerformanceProducer {
                             log.info("------------- DONE (reached the maximum 
number: {} of production) --------------"
                                     , numMessages);
                             doneLatch.countDown();
-                            Thread.sleep(5000);
                             produceEnough = true;
                             break;
                         }