Pipe: Fixed the bug that delete timeSeries / logicalView cannot be transferred (apache#14867)

Author: Caideyipi

integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeIdempotentIT.java

@@ -170,10 +170,10 @@ public void testDeleteTimeSeriesIdempotent() throws Exception {
         Collections.singletonList(
             "create timeSeries root.ln.wf01.wt01.status0(status0) with datatype=BOOLEAN,encoding=PLAIN"),
         "delete timeSeries root.ln.wf01.wt01.status0",
-        "create timeSeries root.ln.wf01.wt01.status2(status2) with datatype=BOOLEAN,encoding=PLAIN",
-        "count timeSeries",
-        "count(timeseries),",
-        Collections.singleton("1,"));
+        "create database root.sg",
+        "count databases",
+        "count,",
+        Collections.singleton("2,"));
   }
 
   @Test
@@ -262,10 +262,10 @@ public void testDeactivateTemplateIdempotent() throws Exception {
             "create timeSeries using device template on root.sg1.d1",
             "create timeSeries using device template on root.sg1.d2"),
         "delete timeSeries of schema template t1 from root.sg1.*",
-        "create timeSeries using device template on root.sg1.d3",
-        "count timeSeries",
-        "count(timeseries),",
-        Collections.singleton("3,"));
+        "create database root.sg2",
+        "count databases",
+        "count,",
+        Collections.singleton("2,"));
   }
 
   @Test

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/payload/PipeDeleteLogicalViewPlan.java

@@ -24,6 +24,8 @@
 
 import org.apache.tsfile.utils.ReadWriteIOUtils;
 
+import javax.annotation.Nonnull;
+
 import java.io.DataOutputStream;
 import java.io.IOException;
 import java.nio.ByteBuffer;
@@ -38,12 +40,13 @@ public PipeDeleteLogicalViewPlan() {
     super(ConfigPhysicalPlanType.PipeDeleteLogicalView);
   }
 
-  public PipeDeleteLogicalViewPlan(final ByteBuffer patternTreeBytes) {
+  public PipeDeleteLogicalViewPlan(final @Nonnull ByteBuffer patternTreeBytes) {
     super(ConfigPhysicalPlanType.PipeDeleteLogicalView);
     this.patternTreeBytes = patternTreeBytes;
   }
 
   public ByteBuffer getPatternTreeBytes() {
+    patternTreeBytes.rewind();
     return patternTreeBytes;
   }
 

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/payload/PipeDeleteTimeSeriesPlan.java

@@ -24,6 +24,8 @@
 
 import org.apache.tsfile.utils.ReadWriteIOUtils;
 
+import javax.annotation.Nonnull;
+
 import java.io.DataOutputStream;
 import java.io.IOException;
 import java.nio.ByteBuffer;
@@ -38,12 +40,13 @@ public PipeDeleteTimeSeriesPlan() {
     super(ConfigPhysicalPlanType.PipeDeleteTimeSeries);
   }
 
-  public PipeDeleteTimeSeriesPlan(final ByteBuffer patternTreeBytes) {
+  public PipeDeleteTimeSeriesPlan(final @Nonnull ByteBuffer patternTreeBytes) {
     super(ConfigPhysicalPlanType.PipeDeleteTimeSeries);
     this.patternTreeBytes = patternTreeBytes;
   }
 
   public ByteBuffer getPatternTreeBytes() {
+    patternTreeBytes.rewind();
     return patternTreeBytes;
   }