(flink) branch master updated: [FLINK-38727][test] Fix flaky test EventTimeWindowCheckpointingITCase#testPreAggregatedSlidingTimeWindow by increasing ResourceManagerOptions.REQUIREMENTS_CHECK_DELAY (#27659)

[panyuepeng]

This is an automated email from the ASF dual-hosted git repository.

panyuepeng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 1719209491d [FLINK-38727][test] Fix flaky test 
EventTimeWindowCheckpointingITCase#testPreAggregatedSlidingTimeWindow by 
increasing ResourceManagerOptions.REQUIREMENTS_CHECK_DELAY (#27659)
1719209491d is described below

commit 1719209491de6ececb488caaaea887dc13affd4e
Author: Shekhar Prasad Rajak <5774448+shekharra...@users.noreply.github.com>
AuthorDate: Sat Apr 11 08:46:45 2026 +0530

    [FLINK-38727][test] Fix flaky test 
EventTimeWindowCheckpointingITCase#testPreAggregatedSlidingTimeWindow by 
increasing ResourceManagerOptions.REQUIREMENTS_CHECK_DELAY (#27659)
---
 .../test/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 0f2b71c5af0..c062a69de19 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.CheckpointingOptions;
 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;
@@ -263,6 +264,12 @@ class EventTimeWindowCheckpointingITCase {
         Configuration config = new Configuration();
         config.set(RpcOptions.FRAMESIZE, 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());