[
https://issues.apache.org/jira/browse/FLINK-40663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18129760#comment-18129760
]
Martijn Visser commented on FLINK-40663:
----------------------------------------
All 37 release-1.20 table jobs that failed on this test since 2026-09-14 (the
36 on the ticket plus the first attempt of the 2026-09-25 nightly) show the
same sequence in the fork log. One AcknowledgeCheckpoint is rejected with the
FLINK-38574 IllegalStateException, that checkpoint expires 600 seconds later
and the job fails on the tolerable-failure threshold. The test is fine;
release-1.20 is the only branch without the FLINK-38574 fix. The backport is
https://github.com/apache/flink/pull/29553. Locally, with CI's flags in a
two-CPU container, the base hit the exception in 1 of 30 runs and the backport
in 0 of 89.
> 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
> Assignee: Martijn Visser
> Priority: Critical
> Labels: test-stability
> Fix For: 1.20.6
>
>
> {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)
