From 6552bfbfc2863ae8ae2c93df00a4cdc7431c201f Mon Sep 17 00:00:00 2001 From: Shekhar Prasad Rajak <5774448+Shekharrajak@users.noreply.github.com> Date: Sat, 11 Apr 2026 08:46:45 +0530 Subject: [PATCH] [FLINK-38727][test] Fix flaky test EventTimeWindowCheckpointingITCase#testPreAggregatedSlidingTimeWindow by increasing ResourceManagerOptions.REQUIREMENTS_CHECK_DELAY (#27659) (cherry picked from commit 1719209491de6ececb488caaaea887dc13affd4e) --- .../checkpointing/EventTimeWindowCheckpointingITCase.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeWindowCheckpointingITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeWindowCheckpointingITCase.java index 161062e682634..fd317e09fca9a 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeWindowCheckpointingITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeWindowCheckpointingITCase.java @@ -29,6 +29,7 @@ import org.apache.flink.configuration.Configuration; import org.apache.flink.configuration.HighAvailabilityOptions; import org.apache.flink.configuration.MemorySize; +import org.apache.flink.configuration.ResourceManagerOptions; import org.apache.flink.configuration.RpcOptions; import org.apache.flink.configuration.StateBackendOptions; import org.apache.flink.configuration.TaskManagerOptions; @@ -270,6 +271,12 @@ protected Configuration createClusterConfig() throws IOException { Configuration config = new Configuration(); config.set(RpcOptions.FRAMESIZE, String.valueOf(MAX_MEM_STATE_SIZE) + "b"); + // FLINK-38727: Increase requirement-check delay to reduce slot manager polling frequency + // under CI load, preventing premature NoResourceAvailableException while TaskManagers + // are registering. SLOT_REQUEST_TIMEOUT (5 min default) already serves as the startup + // grace period via getStandaloneClusterStartupPeriodTime() fallback. + config.set(ResourceManagerOptions.REQUIREMENTS_CHECK_DELAY, Duration.ofSeconds(30)); + if (zkServer != null) { config.set(HighAvailabilityOptions.HA_MODE, "ZOOKEEPER"); config.set(HighAvailabilityOptions.HA_ZOOKEEPER_QUORUM, zkServer.getConnectString());