You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by ma...@apache.org on 2022/09/02 06:49:35 UTC
[pulsar] branch master updated: [fix][test] Fix `ClientDeduplicationFailureTest.testClientDeduplicationWithBkFailure` (#17387)
This is an automated email from the ASF dual-hosted git repository.
mattisonchao 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 bab7faff2d3 [fix][test] Fix `ClientDeduplicationFailureTest.testClientDeduplicationWithBkFailure` (#17387)
bab7faff2d3 is described below
commit bab7faff2d378b2a906b3068277dbd10779d3253
Author: Qiang Zhao <ma...@apache.org>
AuthorDate: Fri Sep 2 14:49:27 2022 +0800
[fix][test] Fix `ClientDeduplicationFailureTest.testClientDeduplicationWithBkFailure` (#17387)
---
.../apache/pulsar/client/api/ClientDeduplicationFailureTest.java | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ClientDeduplicationFailureTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ClientDeduplicationFailureTest.java
index 0d8e87d5151..bc459fde305 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ClientDeduplicationFailureTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ClientDeduplicationFailureTest.java
@@ -48,7 +48,6 @@ import org.apache.pulsar.broker.loadbalance.impl.SimpleLoadManagerImpl;
import org.apache.pulsar.client.admin.BrokerStats;
import org.apache.pulsar.client.admin.PulsarAdmin;
import org.apache.pulsar.client.admin.PulsarAdminException;
-import org.apache.pulsar.client.impl.BatchMessageIdImpl;
import org.apache.pulsar.client.impl.MessageIdImpl;
import org.apache.pulsar.common.policies.data.ClusterData;
import org.apache.pulsar.common.policies.data.RetentionPolicies;
@@ -415,11 +414,11 @@ public class ClientDeduplicationFailureTest {
assertEquals(msgRecvd.get(i).getSequenceId(), i + 10);
}
- BatchMessageIdImpl batchMessageId = (BatchMessageIdImpl) lastMessageId;
+ MessageIdImpl lastMessageIdImpl = (MessageIdImpl) lastMessageId;
MessageIdImpl messageId = (MessageIdImpl) consumer1.getLastMessageId();
- assertEquals(messageId.getLedgerId(), batchMessageId.getLedgerId());
- assertEquals(messageId.getEntryId(), batchMessageId.getEntryId());
+ assertEquals(messageId.getLedgerId(), lastMessageIdImpl.getLedgerId());
+ assertEquals(messageId.getEntryId(), lastMessageIdImpl.getEntryId());
thread.interrupt();
}
}