[
https://issues.apache.org/jira/browse/BEAM-9580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-9580:
-------------------------------
Description:
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=12
--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/]
was:
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/
> 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=12
> --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)
