(iotdb) branch master updated: [Pipe] Stabilize IoTDBPipeAutoSplitIT for auto-dropped history pipe (#18621)

[jiangtian]

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

jt2594838 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 37e3e6630e2 [Pipe] Stabilize IoTDBPipeAutoSplitIT for auto-dropped 
history pipe (#18621)
37e3e6630e2 is described below

commit 37e3e6630e22f420c846e9af371ead0afd568ef4
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Tue Sep 15 09:53:55 2026 +0800

    [Pipe] Stabilize IoTDBPipeAutoSplitIT for auto-dropped history pipe (#18621)
    
    * Test: Stabilize pipe auto split integration test
    
    * Test: Stabilize pipe auto drop integration test
    
    ---------
    
    Co-authored-by: luoluoyuyu <zhe...@apache.org>
---
 .../treemodel/auto/basic/IoTDBPipeAutoSplitIT.java    | 19 +++++++++++++++----
 .../treemodel/auto/enhanced/IoTDBPipeAutoDropIT.java  |  6 ++++++
 2 files changed, 21 insertions(+), 4 deletions(-)

diff --git 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeAutoSplitIT.java
 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeAutoSplitIT.java
index 048f9a19180..4b9012b88ab 100644
--- 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeAutoSplitIT.java
+++ 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeAutoSplitIT.java
@@ -125,15 +125,26 @@ public class IoTDBPipeAutoSplitIT extends 
AbstractPipeDualTreeModelAutoIT {
       final List<TShowPipeInfo> showPipeResult =
           client.showPipe(new 
TShowPipeReq().setUserName(SessionConfig.DEFAULT_USER)).pipeInfoList;
       showPipeResult.removeIf(i -> i.getId().startsWith("__consensus"));
-      Assert.assertEquals(3, showPipeResult.size());
+      // a2b2 is a finite history-only pipe and may have already been 
auto-dropped when there is no
+      // historical data to transfer. The other two pipes must remain and none 
of the pipes should
+      // be split because they are not full-sync pipes.
+      Assert.assertTrue(showPipeResult.stream().anyMatch(i -> 
Objects.equals(i.id, "a2b1")));
+      Assert.assertTrue(showPipeResult.stream().anyMatch(i -> 
Objects.equals(i.id, "a2b3")));
+      Assert.assertTrue(
+          showPipeResult.stream()
+              .allMatch(
+                  i ->
+                      Objects.equals(i.id, "a2b1")
+                          || Objects.equals(i.id, "a2b2")
+                          || Objects.equals(i.id, "a2b3")));
     }
 
     TestUtils.executeNonQueries(
         senderEnv,
         Arrays.asList(
-            "drop pipe a2b1",
-            "drop pipe a2b2",
-            "drop pipe a2b3",
+            "drop pipe if exists a2b1",
+            "drop pipe if exists a2b2",
+            "drop pipe if exists a2b3",
             "insert into root.test.device(time, field) values(0,1),(1,2)",
             "delete from root.test.device.* where time == 0",
             String.format(
diff --git 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeAutoDropIT.java
 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeAutoDropIT.java
index 2d1d7d51f33..fa6694e3be7 100644
--- 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeAutoDropIT.java
+++ 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeAutoDropIT.java
@@ -65,6 +65,12 @@ public class IoTDBPipeAutoDropIT extends 
AbstractPipeDualTreeModelAutoIT {
     super.setUp();
   }
 
+  @Override
+  protected void setupConfig() {
+    super.setupConfig();
+    
senderEnv.getConfig().getConfigNodeConfig().setLeaderDistributionPolicy("HASH");
+  }
+
   @Test
   public void testAutoDropInHistoricalTransfer() throws Exception {
     final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);