[pulsar] branch branch-2.9 updated: [fix][test] Fix jvm oom on Unit Test broker group 1 (#16542)

[bogong]

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

bogong pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.9 by this push:
     new 3fe62401d7f [fix][test] Fix jvm oom on Unit Test broker group 1 
(#16542)
3fe62401d7f is described below

commit 3fe62401d7fd4386d587685a1d574d9d7a1daa05
Author: lipenghui <peng...@apache.org>
AuthorDate: Tue Jul 12 21:13:56 2022 +0800

    [fix][test] Fix jvm oom on Unit Test broker group 1 (#16542)
    
    (cherry picked from commit 3752a1170bd7b362901c3e792548c62352b4b1ad)
---
 .../pulsar/client/api/MultiTopicsConsumerTest.java | 32 ++++++++++------------
 1 file changed, 15 insertions(+), 17 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/MultiTopicsConsumerTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/MultiTopicsConsumerTest.java
index d8c8bd657f8..c8686bfa9c8 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/MultiTopicsConsumerTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/MultiTopicsConsumerTest.java
@@ -65,11 +65,17 @@ public class MultiTopicsConsumerTest extends 
ProducerConsumerBase {
         super.internalCleanup();
     }
 
-    @Override
-    protected PulsarClient createNewPulsarClient(ClientBuilder clientBuilder) 
throws PulsarClientException {
-        ClientConfigurationData conf =
-                ((ClientBuilderImpl) 
clientBuilder).getClientConfigurationData();
-        return new PulsarClientImpl(conf) {
+    // test that reproduces the issue 
https://github.com/apache/pulsar/issues/12024
+    // where closing the consumer leads to an endless receive loop
+    @Test
+    public void testMultiTopicsConsumerCloses() throws Exception {
+        String topicNameBase = 
"persistent://my-property/my-ns/my-topic-consumer-closes-";
+
+        ClientConfigurationData conf = ((ClientBuilderImpl) 
PulsarClient.builder().serviceUrl(lookupUrl.toString()))
+                .getClientConfigurationData();
+
+        @Cleanup
+        PulsarClientImpl client = new PulsarClientImpl(conf) {
             {
                 ScheduledExecutorService internalExecutorService =
                         (ScheduledExecutorService) 
super.getInternalExecutorService();
@@ -85,31 +91,23 @@ public class MultiTopicsConsumerTest extends 
ProducerConsumerBase {
                 return internalExecutorServiceDelegate;
             }
         };
-    }
-
-    // test that reproduces the issue 
https://github.com/apache/pulsar/issues/12024
-    // where closing the consumer leads to an endless receive loop
-    @Test
-    public void testMultiTopicsConsumerCloses() throws Exception {
-        String topicNameBase = 
"persistent://my-property/my-ns/my-topic-consumer-closes-";
-
         @Cleanup
-        Producer<byte[]> producer1 = pulsarClient.newProducer()
+        Producer<byte[]> producer1 = client.newProducer()
                 .topic(topicNameBase + "1")
                 .enableBatching(false)
                 .create();
         @Cleanup
-        Producer<byte[]> producer2 = pulsarClient.newProducer()
+        Producer<byte[]> producer2 = client.newProducer()
                 .topic(topicNameBase + "2")
                 .enableBatching(false)
                 .create();
         @Cleanup
-        Producer<byte[]> producer3 = pulsarClient.newProducer()
+        Producer<byte[]> producer3 = client.newProducer()
                 .topic(topicNameBase + "3")
                 .enableBatching(false)
                 .create();
 
-        Consumer<byte[]> consumer = pulsarClient
+        Consumer<byte[]> consumer = client
                 .newConsumer()
                 .topics(Lists.newArrayList(topicNameBase + "1", topicNameBase 
+ "2", topicNameBase + "3"))
                 
.subscriptionInitialPosition(SubscriptionInitialPosition.Earliest)