You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pa...@apache.org on 2026/04/11 03:16:51 UTC
(flink) branch master updated: [FLINK-38727][test] Fix flaky test EventTimeWindowCheckpointingITCase#testPreAggregatedSlidingTimeWindow by increasing ResourceManagerOptions.REQUIREMENTS_CHECK_DELAY (#27659)
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 <57...@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());