[BEAM-9580] Nexmark Query 12 in streaming mode is stuck on Flink Runner with Flink 1.10

• Type: Bug
• Status: Resolved
• Priority: P1
• Resolution: Fixed
• Affects Version/s: 2.21.0
• Fix Version/s: 2.21.0
• Component/s: runner-flink
• Labels: nexmark
• Assignee: Maximilian Michels
• Reporter: Ismaël Mejía
• Created: 24/Mar/20 09:48
• Updated: 24/Jul/20 20:00
• Resolved: 08/Apr/20 17:52

Description

You can reproduce by running:

./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

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/

Issue Links

• is related to: BEAM-9295 Add Flink 1.10 build target and Make FlinkRunner compatible with Flink 1.10
• links to: GitHub Pull Request #11346