[
https://issues.apache.org/jira/browse/BEAM-9580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17065467#comment-17065467
]
Ismaël Mejía commented on BEAM-9580:
------------------------------------
Query 12 uses an 'advanced' trigger, so maybe is stuck there.
{quote}.apply(
Window.<Long>into(new GlobalWindows())
.triggering(
Repeatedly.forever(
AfterProcessingTime.pastFirstElementInPane()
.plusDelayOf(Duration.standardSeconds(configuration.windowSizeSec))))
.discardingFiredPanes()
{quote}
> 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
> Priority: Critical
>
> 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)
