[BEAM-12636] Windowing transform not working for sdk-go on Dataflow?

• Type: Bug
• Status: Resolved
• Priority: P3
• Resolution: Information Provided
• Affects Version/s: 2.31.0
• Fix Version/s: Missing
• Component/s: runner-dataflow, sdk-go

Language

Go

• Assignee: Unassigned
• Reporter: Claudio Prates
• Created: 19/Jul/21 15:09
• Updated: 16/Mar/23 13:15
• Resolved: 13/Jan/22 20:03

Description

Hi, I'm trying to run the example windowed_wordcount on Dataflow but it doesn't seems to be working.

When I try to run it, the only error I get from the logs in Dataflow is "Error processing pipeline". When I change the example to not use windowing all works fine.

The version of the SDK I'm using is 2.31.0. Tried up to 2.26.0 and all have the same behaviour.

And I'm running the example with

go run main.go --runner=dataflow --region=europe-west1 --project=<project> --staging_location=gs://bucket/path --temp_location=gs://bucket/path --max_num_workers=1

Also tried the with

go run main.go --runner=dataflow --region=europe-west1 --project=<project> --staging_location=gs://bucket/path --temp_location=gs://bucket/path --max_num_workers=1 -worker_harness_container_image=apache/beam_go_sdk:latest --experiments=use_runner_v2

Is this actually a bug or am I make some mistake running the example?