From acb5df18e0bf948d1f8ce94f2d50f5aaa6b18698 Mon Sep 17 00:00:00 2001
From: liyuheng <liyuheng55555@126.com>
Date: Mon, 20 Jan 2025 18:11:07 +0800
Subject: [PATCH] try to fix IoTDBPipeInclusionIT.testPureDeleteInclusion

---
 .../plan/node/pipe/PipeEnrichedDeleteDataNode.java       | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/pipe/PipeEnrichedDeleteDataNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/pipe/PipeEnrichedDeleteDataNode.java
index 1addd585e48a..973e71e97b5a 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/pipe/PipeEnrichedDeleteDataNode.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/pipe/PipeEnrichedDeleteDataNode.java
@@ -199,6 +199,13 @@ public int serializedSize() {
 
   @Override
   public SearchNode merge(List<SearchNode> searchNodes) {
-    return deleteDataNode.merge(searchNodes);
+    List<SearchNode> unrichedDeleteDataNodes =
+        searchNodes.stream()
+            .map(
+                searchNode ->
+                    (SearchNode) ((PipeEnrichedDeleteDataNode) searchNode).getDeleteDataNode())
+            .collect(Collectors.toList());
+    return new PipeEnrichedDeleteDataNode(
+        (DeleteDataNode) deleteDataNode.merge(unrichedDeleteDataNodes));
   }
 }