[
https://issues.apache.org/jira/browse/BEAM-9580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17065506#comment-17065506
]
Ismaël Mejía commented on BEAM-9580:
------------------------------------
I tried the same query with 1.9 in master and it passes so it seems to be
related to the recently added support for Flink 1.10
> 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
> Reporter: Ismaël Mejía
> Assignee: Maximilian Michels
> Priority: Critical
> 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)
