fix

Pengzna · Pengzna · commit 08f06af87ec4 · 2025-09-01T23:58:28.000+08:00
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/AbstractOperatePipeProcedureV2.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/AbstractOperatePipeProcedureV2.java
@@ -624,6 +624,8 @@ public void serialize(DataOutputStream stream) throws IOException {
   public void deserialize(ByteBuffer byteBuffer) {
     super.deserialize(byteBuffer);
     isRollbackFromOperateOnDataNodesSuccessful = ReadWriteIOUtils.readBool(byteBuffer);
-    lockSeqId = ReadWriteIOUtils.readLong(byteBuffer);
+    if (byteBuffer.remaining() >= Long.BYTES) {
+      lockSeqId = ReadWriteIOUtils.readLong(byteBuffer);
+    }
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -624,6 +624,8 @@ public void serialize(DataOutputStream stream) throws IOException {`
`624`	`624`	`public void deserialize(ByteBuffer byteBuffer) {`
`625`	`625`	`super.deserialize(byteBuffer);`
`626`	`626`	`isRollbackFromOperateOnDataNodesSuccessful = ReadWriteIOUtils.readBool(byteBuffer);`
`627`		`- lockSeqId = ReadWriteIOUtils.readLong(byteBuffer);`
	`627`	`+ if (byteBuffer.remaining() >= Long.BYTES) {`
	`628`	`+ lockSeqId = ReadWriteIOUtils.readLong(byteBuffer);`
	`629`	`+ }`
`628`	`630`	`}`
`629`	`631`	`}`