From 24d030f5f2c02500e11b49aced1f9ef9a16612cc Mon Sep 17 00:00:00 2001 From: wangxye Date: Tue, 14 Nov 2023 09:41:33 +0800 Subject: [PATCH] fix: fix the simple param and load balance test Signed-off-by: wangxye --- .../java/org/apache/rocketmq/cluster/LoadBalancingTest.java | 2 ++ .../java/org/apache/rocketmq/broker/simple/SimpleParamTest.java | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/java/e2e-v4/src/test/java/org/apache/rocketmq/cluster/LoadBalancingTest.java b/java/e2e-v4/src/test/java/org/apache/rocketmq/cluster/LoadBalancingTest.java index 600a941..8309abd 100644 --- a/java/e2e-v4/src/test/java/org/apache/rocketmq/cluster/LoadBalancingTest.java +++ b/java/e2e-v4/src/test/java/org/apache/rocketmq/cluster/LoadBalancingTest.java @@ -117,6 +117,8 @@ public Boolean call() throws Exception { consumer3.shutdown(); consumer4.shutdown(); + VerifyUtils.waitForLoadBalance(topic, consumer1, consumer2); + producer.send(topic, tag, messageSize); await().atMost(120, SECONDS).until(new Callable() { diff --git a/java/e2e/src/test/java/org/apache/rocketmq/broker/simple/SimpleParamTest.java b/java/e2e/src/test/java/org/apache/rocketmq/broker/simple/SimpleParamTest.java index d5acf66..52c3849 100644 --- a/java/e2e/src/test/java/org/apache/rocketmq/broker/simple/SimpleParamTest.java +++ b/java/e2e/src/test/java/org/apache/rocketmq/broker/simple/SimpleParamTest.java @@ -131,7 +131,7 @@ public void test_waitAckException_reReceive_ack() { if (messageViews.size() > 0) { for (MessageView messageView : messageViews) { log.info("MessageId:{}, Body:{}, tag:{}, property:{}", messageView.getMessageId(), StandardCharsets.UTF_8.decode(messageView.getBody()).toString(), messageView.getTag().get(), messageView.getProperties()); - TestUtils.waitForSeconds(15); + TestUtils.waitForSeconds(20); consumer.ack(messageView); Assertions.fail("Calling changeInvisibleDuration after ack fails with an INVALID_RECEIPT_HANDLE error"); }