This is an automated email from the ASF dual-hosted git repository. Caideyipi pushed a commit to branch codex/fix-show-receivers-lifecycle in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 148f146e8cf9f8b3aa1a63bad4aaf04f1568d956 Author: Caideyipi <[email protected]> AuthorDate: Fri Oct 30 12:29:05 2026 +0800 Fix flaky SHOW RECEIVERS lifecycle assertions --- .../it/dual/treemodel/auto/basic/IoTDBShowReceiversLifecycleIT.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBShowReceiversLifecycleIT.java b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBShowReceiversLifecycleIT.java index e3ccb2b0695..f08e7f3b4e5 100644 --- a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBShowReceiversLifecycleIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBShowReceiversLifecycleIT.java @@ -247,11 +247,13 @@ public class IoTDBShowReceiversLifecycleIT extends AbstractPipeDualTreeModelAuto private void assertShowReceiversDoesNotContainPipe( final String sql, final String sqlDialect, final String pipeName) { + // Pipe connections close asynchronously, so DataNodes may observe different snapshots. Awaitility.await() .pollInSameThread() .pollDelay(1L, TimeUnit.SECONDS) .pollInterval(1L, TimeUnit.SECONDS) .atMost(60L, TimeUnit.SECONDS) + .ignoreExceptionsMatching(e -> e instanceof InconsistentDataException) .untilAsserted(() -> Assert.assertFalse(containsPipe(sql, sqlDialect, pipeName))); } @@ -279,6 +281,7 @@ public class IoTDBShowReceiversLifecycleIT extends AbstractPipeDualTreeModelAuto .pollDelay(1L, TimeUnit.SECONDS) .pollInterval(1L, TimeUnit.SECONDS) .atMost(60L, TimeUnit.SECONDS) + .ignoreExceptionsMatching(e -> e instanceof InconsistentDataException) .untilAsserted( () -> Assert.assertTrue(hasDataNodeAndConfigNodeReceivers(sql, sqlDialect, pipeName))); } @@ -317,6 +320,7 @@ public class IoTDBShowReceiversLifecycleIT extends AbstractPipeDualTreeModelAuto .pollDelay(1L, TimeUnit.SECONDS) .pollInterval(1L, TimeUnit.SECONDS) .atMost(60L, TimeUnit.SECONDS) + .ignoreExceptionsMatching(e -> e instanceof InconsistentDataException) .untilAsserted( () -> Assert.assertTrue(
