This is an automated email from the ASF dual-hosted git repository. github-merge-queue[bot] pushed a commit to branch gh-readonly-queue/dev/pr-12381-b3211fb1ca36f1a7f7dbd60ebb036de3f798ae10 in repository https://gitbox.apache.org/repos/asf/seatunnel.git
commit a5efad47c59b13606792f4ca3f8357d6dfd3e829 Author: Jast <[email protected]> AuthorDate: Fri Oct 2 07:39:17 2026 +0000 [Test] Widen timing budgets in stall-sensitive unit tests (#12381) Co-authored-by: jast <[email protected]> --- .../agent/connector/file/FileCollectReaderBehaviorTest.java | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/seatunnel-edge-agent/seatunnel-edge-agent-connector/src/test/java/org/apache/seatunnel/edge/agent/connector/file/FileCollectReaderBehaviorTest.java b/seatunnel-edge-agent/seatunnel-edge-agent-connector/src/test/java/org/apache/seatunnel/edge/agent/connector/file/FileCollectReaderBehaviorTest.java index a4d624b65a..0f15f67181 100644 --- a/seatunnel-edge-agent/seatunnel-edge-agent-connector/src/test/java/org/apache/seatunnel/edge/agent/connector/file/FileCollectReaderBehaviorTest.java +++ b/seatunnel-edge-agent/seatunnel-edge-agent-connector/src/test/java/org/apache/seatunnel/edge/agent/connector/file/FileCollectReaderBehaviorTest.java @@ -45,6 +45,12 @@ public class FileCollectReaderBehaviorTest { private static final long CLOSE_INACTIVE_MS = 500L; private static final long GLOB_SCAN_INTERVAL_MS = 20L; + // Ceiling for the wall-clock choreography below. The common case finishes in milliseconds, + // but the conditions depend on real filesystem scans plus the idle windows above, so keep + // the ceiling well above both: stalled CI runners (Windows runners have shown multi-second + // scheduling stalls) must fail on reader behavior, not on scheduling delay. + private static final long AWAIT_BUDGET_SECONDS = 10L; + @TempDir Path tempDir; @Test @@ -71,7 +77,7 @@ public class FileCollectReaderBehaviorTest { long idleDeadlineMs = System.currentTimeMillis() + CLOSE_INACTIVE_MS + 30L; Awaitility.await() - .atMost(3, TimeUnit.SECONDS) + .atMost(AWAIT_BUDGET_SECONDS, TimeUnit.SECONDS) .pollInterval(GLOB_SCAN_INTERVAL_MS, TimeUnit.MILLISECONDS) .until( () -> { @@ -81,7 +87,7 @@ public class FileCollectReaderBehaviorTest { // Ensure glob scan rediscovers the file before new data is appended Awaitility.await() - .atMost(3, TimeUnit.SECONDS) + .atMost(AWAIT_BUDGET_SECONDS, TimeUnit.SECONDS) .pollInterval(5, TimeUnit.MILLISECONDS) .until( () -> { @@ -96,7 +102,7 @@ public class FileCollectReaderBehaviorTest { "second\n".getBytes(StandardCharsets.UTF_8), StandardOpenOption.APPEND); - await().atMost(3, TimeUnit.SECONDS) + await().atMost(AWAIT_BUDGET_SECONDS, TimeUnit.SECONDS) .pollInterval(10, TimeUnit.MILLISECONDS) .untilAsserted( () -> {
