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 3a51384b2dc Fix flaky SHOW RECEIVERS lifecycle assertions (#19061)
3a51384b2dc is described below
commit 3a51384b2dcc8c29118b7d082c829450c4408b4c
Author: Caideyipi <[email protected]>
AuthorDate: Fri Oct 30 14:23:28 2026 +0800
Fix flaky SHOW RECEIVERS lifecycle assertions (#19061)
---
.../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(
