From cf918764eb94123c05557b5f968ac7b2e5f57cd9 Mon Sep 17 00:00:00 2001 From: Caideyipi <87789683+Caideyipi@users.noreply.github.com> Date: Wed, 29 Jul 2026 10:05:51 +0800 Subject: [PATCH] [Pipe] Relax flaky TsFile event test timeouts (#18332) --- .../iotdb/db/pipe/event/PipeTsFileInsertionEventTest.java | 2 +- .../common/tsfile/PipeTsFileInsertionEventAdmissionTest.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/PipeTsFileInsertionEventTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/PipeTsFileInsertionEventTest.java index fd824d2d25712..b30cf4f98e3f5 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/PipeTsFileInsertionEventTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/PipeTsFileInsertionEventTest.java @@ -37,7 +37,7 @@ public class PipeTsFileInsertionEventTest { - @Test(timeout = 5000) + @Test(timeout = 60000) public void testRealtimeEventCanSkipWaitingForClosedStatusAfterTsFileSealed() throws Exception { final File tempDir = Files.createTempDirectory("pipeTsFileSealed").toFile(); diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/common/tsfile/PipeTsFileInsertionEventAdmissionTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/common/tsfile/PipeTsFileInsertionEventAdmissionTest.java index 59d613bb0266a..c39d56ed2fc8e 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/common/tsfile/PipeTsFileInsertionEventAdmissionTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/common/tsfile/PipeTsFileInsertionEventAdmissionTest.java @@ -44,7 +44,7 @@ public class PipeTsFileInsertionEventAdmissionTest { - @Test(timeout = 10000) + @Test(timeout = 60000) public void testParserAdmissionIsWokenWhenMemoryIsReleased() throws Exception { final CommonConfig commonConfig = CommonDescriptor.getInstance().getConfig(); final PipeMemoryManager memoryManager = PipeDataNodeResourceManager.memory();