You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/09/24 10:23:00 UTC
[jira] [Reopened] (FLINK-38727) Unstable test cases EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow
[ https://issues.apache.org/jira/browse/FLINK-38727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Martijn Visser reopened FLINK-38727:
------------------------------------
Reopening for the release-2.2 backport. Four more on release-2.2 this week. Three of them look different from before and only in the AdaptiveScheduler profile: the job runs at parallelism 2 instead of 4 and the parallelism assertion fails after about 15 s, instead of the 300 s resource timeout.
https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=79373&view=logs&j=8fd9202e-fd17-5b26-353c-ac1ff76c8f28 (nightly 2026-09-24, FORST_INCREMENTAL)
https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=79342&view=logs&j=8fd9202e-fd17-5b26-353c-ac1ff76c8f28 (nightly 2026-09-23)
https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=79268&view=logs&j=8fd9202e-fd17-5b26-353c-ac1ff76c8f28 (nightly 2026-09-20)
{code}
[ERROR] org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow[statebackend type =ROCKSDB_INCREMENTAL] -- Time elapsed: 17.33 s <<< ERROR!
Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=1, backoffTimeMS=0)
Caused by: java.lang.AssertionError: expected:<4> but was:<2>
at org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase$7.open(EventTimeWindowCheckpointingITCase.java:674)
{code}
The fourth is the known NoResourceAvailableException after 300 s, on a push: https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=79296&view=logs&j=5c8e7682-d68f-54d1-16a2-a09310218a49
Neither shape shows up on master or release-2.3, which have 1719209491d, in 74 runs of the same module. The release-2.2 backport is still open. Proposing Critical rather than Minor.
[optional] #29224 would remove the delay from master again, while release-2.2, the one branch without it, is the one still failing.
> Unstable test cases EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow
> -----------------------------------------------------------------------------------------
>
> Key: FLINK-38727
> URL: https://issues.apache.org/jira/browse/FLINK-38727
> Project: Flink
> Issue Type: Bug
> Components: Tests
> Reporter: RocMarshal
> Assignee: Shekhar Prasad Rajak
> Priority: Minor
> Labels: pull-request-available, test-stability
> Fix For: 2.3.0
>
>
> {noformat}
> Feb 12 14:45:55 14:45:55.387 [ERROR] Tests run: 36, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 441.3 s <<< FAILURE! -- in org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase
> Feb 12 14:45:55 14:45:55.387 [ERROR] org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow[statebackend type =FORST_INCREMENTAL] -- Time elapsed: 300.2 s <<< ERROR!
> Feb 12 14:45:55 org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> Feb 12 14:45:55 at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:147)
> Feb 12 14:45:55 at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:140)
> Feb 12 14:45:55 at java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:646)
> Feb 12 14:45:55 at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
> (...)
> Feb 12 14:45:55 Caused by: java.util.concurrent.CompletionException: java.util.concurrent.CompletionException: org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Could not acquire the minimum required resources.
> Feb 12 14:45:55 at org.apache.flink.runtime.scheduler.DefaultExecutionDeployer.lambda$assignResource$4(DefaultExecutionDeployer.java:226)
> Feb 12 14:45:55 ... 37 more
> Feb 12 14:45:55 Caused by: java.util.concurrent.CompletionException: org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Could not acquire the minimum required resources.
> Feb 12 14:45:55 at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:332)
> Feb 12 14:45:55 at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:347)
> Feb 12 14:45:55 at java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:636)
> Feb 12 14:45:55 ... 35 more
> Feb 12 14:45:55 Caused by: org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Could not acquire the minimum required resources.
> Feb 12 14:45:55
> Feb 12 14:50:03 14:50:03.108 [ERROR] Errors:
> Feb 12 14:50:03 14:50:03.108 [ERROR] EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow[statebackend type =FORST_INCREMENTAL] ยป JobExecution Job execution failed.
> {noformat}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=71075&view=logs&j=5c8e7682-d68f-54d1-16a2-a09310218a49&t=9d734c8c-6253-55e6-3bce-47e7cdf68ac4
--
This message was sent by Atlassian Jira
(v8.20.10#820010)