(iotdb) branch master updated: IoTConsensusV2: Fix adoption for table-deletion #14648

[tanxinyu]

This is an automated email from the ASF dual-hosted git repository.

tanxinyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new d60c3d52cb1 IoTConsensusV2: Fix adoption for table-deletion #14648
d60c3d52cb1 is described below

commit d60c3d52cb1d5e2847c6639c4c6e792630a8e8e3
Author: Peng Junzhi <78788603+peng...@users.noreply.github.com>
AuthorDate: Wed Jan 8 11:21:19 2025 +0800

    IoTConsensusV2: Fix adoption for table-deletion #14648
---
 .../pipeconsensus/payload/request/PipeConsensusDeleteNodeReq.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/payload/request/PipeConsensusDeleteNodeReq.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/payload/request/PipeConsensusDeleteNodeReq.java
index c8bc33bb52a..f0e71db4f8e 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/payload/request/PipeConsensusDeleteNodeReq.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/payload/request/PipeConsensusDeleteNodeReq.java
@@ -27,7 +27,6 @@ import org.apache.iotdb.consensus.pipe.thrift.TCommitId;
 import org.apache.iotdb.consensus.pipe.thrift.TPipeConsensusTransferReq;
 import org.apache.iotdb.db.queryengine.plan.planner.plan.node.PlanNodeType;
 import 
org.apache.iotdb.db.queryengine.plan.planner.plan.node.write.AbstractDeleteDataNode;
-import 
org.apache.iotdb.db.queryengine.plan.planner.plan.node.write.DeleteDataNode;
 
 import org.apache.tsfile.utils.PublicBAOS;
 import org.slf4j.Logger;
@@ -85,7 +84,8 @@ public class PipeConsensusDeleteNodeReq extends 
TPipeConsensusTransferReq {
       TPipeConsensusTransferReq transferReq) {
     final PipeConsensusDeleteNodeReq deleteNodeReq = new 
PipeConsensusDeleteNodeReq();
 
-    deleteNodeReq.deleteDataNode = (DeleteDataNode) 
PlanNodeType.deserialize(transferReq.body);
+    deleteNodeReq.deleteDataNode =
+        (AbstractDeleteDataNode) PlanNodeType.deserialize(transferReq.body);
 
     deleteNodeReq.version = transferReq.version;
     deleteNodeReq.type = transferReq.type;