try to fix IoTDBPipeInclusionIT.testPureDeleteInclusion

apache · Jan 20, 2025 · acb5df1 · acb5df1
1 parent 5fd1ecd
commit acb5df1
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/...g/apache/iotdb/db/queryengine/plan/planner/plan/node/pipe/PipeEnrichedDeleteDataNode.java b/...g/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));
   }
 }