You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by bo...@apache.org on 2022/11/08 07:23:32 UTC
[pulsar] branch branch-2.9 updated: [fix][test] Fix jvm oom on Unit Test broker group 1 (#16542)
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 <pe...@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)