[
https://issues.apache.org/jira/browse/BEAM-9580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17065564#comment-17065564
]
Maximilian Michels commented on BEAM-9580:
------------------------------------------
Yes, can confirm that it only affects Flink 1.10.
> Nexmark Query 12 in streaming mode is stuck on Flink Runner with Flink 1.10
> ---------------------------------------------------------------------------
>
> Key: BEAM-9580
> URL: https://issues.apache.org/jira/browse/BEAM-9580
> Project: Beam
> Issue Type: Bug
> Components: runner-flink
> Affects Versions: 2.21.0
> Reporter: Ismaël Mejía
> Assignee: Maximilian Michels
> Priority: Critical
> Labels: nexmark
> Fix For: 2.21.0
>
>
> 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)
