Fix pipe plan node byte buffer test

Caideyipi · Caideyipi · commit bebe1002934c · 2026-06-29T12:02:10.000+08:00
diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/PipeDataNodeThriftRequestTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/PipeDataNodeThriftRequestTest.java
@@ -429,6 +429,7 @@ public void testPipeTransferPlanNodeReqBytesWithPartialDirectByteBuffer() throws
     Assert.assertEquals(
         PipeRequestType.TRANSFER_PLAN_NODE.getType(), ReadWriteIOUtils.readShort(transferBuffer));
     Assert.assertEquals(node, PlanNodeType.deserialize(transferBuffer));
+    Assert.assertEquals(0, ReadWriteIOUtils.readInt(transferBuffer));
     Assert.assertFalse(transferBuffer.hasRemaining());
   }
 

Original file line number	Diff line number	Diff line change
`@@ -429,6 +429,7 @@ public void testPipeTransferPlanNodeReqBytesWithPartialDirectByteBuffer() throws`
`429`	`429`	`Assert.assertEquals(`
`430`	`430`	`PipeRequestType.TRANSFER_PLAN_NODE.getType(), ReadWriteIOUtils.readShort(transferBuffer));`
`431`	`431`	`Assert.assertEquals(node, PlanNodeType.deserialize(transferBuffer));`
	`432`	`+ Assert.assertEquals(0, ReadWriteIOUtils.readInt(transferBuffer));`
`432`	`433`	`Assert.assertFalse(transferBuffer.hasRemaining());`
`433`	`434`	`}`
`434`	`435`