[
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)
