Ismaël Mejía created BEAM-9580:
----------------------------------
Summary: Nexmark Query 12 in streaming mode is stuck on Flink
Runner
Key: BEAM-9580
URL: https://issues.apache.org/jira/browse/BEAM-9580
Project: Beam
Issue Type: Bug
Components: runner-flink
Affects Versions: 2.20.0
Reporter: Ismaël Mejía
Assignee: Maximilian Michels
You can reproduce by running:
{quote}./gradlew :sdks:java:testing:nexmark:run \
-Pnexmark.runner=":runners:flink:1.10" \
-Pnexmark.args="
--runner=FlinkRunner
--streaming=true --shutdownSourcesOnFinalWatermark=true --query=11
--suite=SMOKE
--manageResources=false
--monitorJobs=true
--enforceEncodability=true
{quote}
I stumbled into this while updating the Nexmark dashboards for the Flink runner
It seems to be failing since
https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/5259/
--
This message was sent by Atlassian Jira
(v8.3.4#803005)