From c32e4c1f2fc55be5c1f5c4b0ac5d21c2a060c24b Mon Sep 17 00:00:00 2001 From: JiangHaiting Date: Mon, 1 Aug 2022 20:00:32 +0800 Subject: [PATCH] fix testTxnCommitMarker --- .../apache/pulsar/common/protocol/MarkersTest.java | 13 ------------- 1 file changed, 13 deletions(-) diff --git a/pulsar-common/src/test/java/org/apache/pulsar/common/protocol/MarkersTest.java b/pulsar-common/src/test/java/org/apache/pulsar/common/protocol/MarkersTest.java index 620cb35e56122f..c1e857487bf13b 100644 --- a/pulsar-common/src/test/java/org/apache/pulsar/common/protocol/MarkersTest.java +++ b/pulsar-common/src/test/java/org/apache/pulsar/common/protocol/MarkersTest.java @@ -19,18 +19,13 @@ package org.apache.pulsar.common.protocol; import static org.testng.Assert.assertEquals; -import static org.testng.Assert.assertTrue; -import static org.testng.Assert.fail; - import io.netty.buffer.ByteBuf; - import java.io.IOException; import java.util.ArrayList; import java.util.Collections; import java.util.List; import java.util.Map; import java.util.TreeMap; - import lombok.extern.slf4j.Slf4j; import org.apache.pulsar.common.api.proto.PulsarApi.MessageMetadata; import org.apache.pulsar.common.api.proto.PulsarMarkers; @@ -139,14 +134,6 @@ public void testTxnCommitMarker() throws IOException { } ByteBuf buf = Markers.newTxnCommitMarker(sequenceId, mostBits, leastBits, messageIdDataList); - for (MessageIdData messageIdData : messageIdDataList) { - try { - messageIdData.recycle(); - fail("message id data should be recycled after create the marker bytebuf."); - } catch (Exception e) { - assertTrue(e instanceof java.lang.IllegalStateException); - } - } MessageMetadata msgMetadata = Commands.parseMessageMetadata(buf); assertEquals(msgMetadata.getMarkerType(), PulsarMarkers.MarkerType.TXN_COMMIT_VALUE);