Skip to content

[Pipe] Stabilize IoTDBPipeAutoSplitIT for auto-dropped history pipe #18621

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
Caideyipi wants to merge 2 commits into
base: master
Choose a base branch
from
+21 −4
Open

[Pipe] Stabilize IoTDBPipeAutoSplitIT for auto-dropped history pipe #18621

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
547e251
Test: Stabilize pipe auto split integration test
Caideyipi Sep 10, 2026
f6c1848
Test: Stabilize pipe auto drop integration test
luoluoyuyu Sep 11, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
19 changes: 15 additions & 4 deletions ...rc/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeAutoSplitIT.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -125,15 +125,26 @@ public void testSingleEnv() throws Exception {
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(
Expand Down
6 changes: 6 additions & 0 deletions .../test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeAutoDropIT.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -65,6 +65,12 @@ public void setUp() {
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);
Expand Down