[jira] [Created] (FLINK-40906) DataFrameWindowITTests.test_hop_window_aggregation fails with a DispatcherGateway.submitJob timeout

["Martijn Visser (Jira)" <ji...@apache.org>]

Martijn Visser created FLINK-40906:
--------------------------------------

             Summary: DataFrameWindowITTests.test_hop_window_aggregation fails with a DispatcherGateway.submitJob timeout
                 Key: FLINK-40906
                 URL: https://issues.apache.org/jira/browse/FLINK-40906
             Project: Flink
          Issue Type: Bug
          Components: API / Python
    Affects Versions: 2.4.0
            Reporter: Martijn Visser


https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=79750&view=logs&j=00b6b22f-2e0b-5861-de1c-fd8f5bdfb924 (master, nightly 2026-10-04, Hadoop 3.4.3 profile, JDK 17, Python 3.11)

{code}
FAILED pyflink/dataframe/tests/test_dataframe.py::DataFrameWindowITTests::test_hop_window_aggregation
...
E       pyflink.util.exceptions.TableException: org.apache.flink.table.api.TableException: Failed to execute sql
...
E       Caused by: org.apache.flink.util.FlinkException: Failed to execute job 'collect'.
...
E       Caused by: java.util.concurrent.TimeoutException: Invocation of [LocalRpcInvocation(DispatcherGateway.submitJob(ExecutionPlan, Duration))] at recipient [pekko.tcp://flink@localhost:36770/user/rpc/dispatcher_198] timed out. ...
E               at org.apache.flink.runtime.rpc.pekko.$Proxy118.submitJob(Unknown Source)
E               at org.apache.flink.runtime.application.SingleJobApplication.execute(SingleJobApplication.java:94)
E               at org.apache.flink.runtime.dispatcher.Dispatcher.internalSubmitApplication(Dispatcher.java:1005)
...
E       Caused by: org.apache.pekko.pattern.AskTimeoutException: Ask timed out on [Actor[pekko://flink/user/rpc/dispatcher_198#-2025310980]] after [10000 ms]. Message of type [org.apache.flink.runtime.rpc.messages.LocalFencedMessage]. A typical reason for `AskTimeoutException` is that the recipient actor didn't send a reply.
{code}

The Flink log in the build's python artifact shows the dispatcher proposing leadership for this job at 01:48:13,316 and the JobMasterServiceLeadershipRunner being granted it at 01:48:44,618, after the submission had already timed out at 01:48:23,333. Nothing else was logged in that window. The other five jobs this test class submitted to the same dispatcher were granted leadership within 1 ms.

The test was added with FLINK-40424 and only exists on master. It passed on the other five python legs of the same build, and this is the only occurrence in 74 master runs over the last seven days.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)