[
https://issues.apache.org/jira/browse/FLINK-40663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18129628#comment-18129628
]
Martijn Visser commented on FLINK-40663:
----------------------------------------
Two more jobs on the release-1.20 nightly of 2026-10-21:
2026-10-21 (Java 17):
https://github.com/apache/flink/actions/runs/39531020653/job/119010155405
2026-10-21 (Hadoop 3.1.3):
https://github.com/apache/flink/actions/runs/39531020653/job/119010041030
{code}
[ERROR]
org.apache.flink.table.planner.runtime.stream.sql.WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure
-- Time elapsed: 612.8 s <<< ERROR!
java.util.concurrent.ExecutionException:
org.apache.flink.table.api.TableException: Failed to wait job finish
...
Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by
FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=1,
backoffTimeMS=0)
Caused by: org.apache.flink.util.FlinkRuntimeException: Exceeded checkpoint
tolerable failure threshold. The latest checkpoint failed due to Checkpoint
expired before completing., view the Checkpoint History tab or the Job Manager
log to find out why continuous checkpoints failed.
{code}
> WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure
> times out after 600s
> ---------------------------------------------------------------------------------------------------
>
> Key: FLINK-40663
> URL: https://issues.apache.org/jira/browse/FLINK-40663
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Runtime
> Affects Versions: 1.20.6
> Reporter: Martijn Visser
> Priority: Critical
> Labels: test-stability
>
> {code}
> [ERROR]
> org.apache.flink.table.planner.runtime.stream.sql.WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure
> -- Time elapsed: 617.2 s <<< ERROR!
> java.util.concurrent.ExecutionException:
> org.apache.flink.table.api.TableException: Failed to wait job finish
> at
> java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395)
> at
> org.apache.flink.table.api.internal.TableResultImpl.awaitInternal(TableResultImpl.java:122)
> at
> org.apache.flink.table.planner.runtime.stream.sql.WindowDistinctAggregateStressITCase.runQuery(WindowDistinctAggregateStressITCase.java:191)
> at
> org.apache.flink.table.planner.runtime.stream.sql.WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure(WindowDistinctAggregateStressITCase.java:149)
> Caused by: org.apache.flink.table.api.TableException: Failed to wait job
> finish
> at
> org.apache.flink.table.api.internal.InsertResultProvider.hasNext(InsertResultProvider.java:85)
> {code}
> Three occurrences in the window, on two different profiles and on both a
> nightly and a push run:
> https://github.com/apache/flink/actions/runs/34919682822 (nightly 2026-09-15,
> Java 11)
> https://github.com/apache/flink/actions/runs/34798014224 (nightly 2026-09-14,
> Java 17)
> https://github.com/apache/flink/actions/runs/34861606726 (push 2026-09-14,
> Java 8)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
