You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2022/04/13 03:03:34 UTC
[pulsar] branch branch-2.8 updated: Fix MemoryLimitTest for branch-2.8 (#15138)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.8 by this push:
new bb7670b20d8 Fix MemoryLimitTest for branch-2.8 (#15138)
bb7670b20d8 is described below
commit bb7670b20d8690bee9a6176490574e3c13ca3093
Author: lipenghui <pe...@apache.org>
AuthorDate: Wed Apr 13 11:03:24 2022 +0800
Fix MemoryLimitTest for branch-2.8 (#15138)
---
.../src/test/java/org/apache/pulsar/client/api/MemoryLimitTest.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/MemoryLimitTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/MemoryLimitTest.java
index 431991e61aa..2541af947c3 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/MemoryLimitTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/MemoryLimitTest.java
@@ -76,6 +76,7 @@ public class MemoryLimitTest extends ProducerConsumerBase {
.topic(topic)
.blockIfQueueFull(false)
.sendTimeout(5, TimeUnit.SECONDS)
+ .enableBatching(false)
.create();
// make sure all message pending at pendingMessages queue
@@ -124,6 +125,7 @@ public class MemoryLimitTest extends ProducerConsumerBase {
.topic(t1)
.blockIfQueueFull(false)
.sendTimeout(5, TimeUnit.SECONDS)
+ .enableBatching(false)
.create();
@Cleanup
@@ -131,6 +133,7 @@ public class MemoryLimitTest extends ProducerConsumerBase {
.topic(t2)
.blockIfQueueFull(false)
.sendTimeout(5, TimeUnit.SECONDS)
+ .enableBatching(false)
.create();
client.dropOpSendMessages();