Claudio Prates created BEAM-12636:
-------------------------------------
Summary: Windowing transform not working for sdk-go on Dataflow?
Key: BEAM-12636
URL: https://issues.apache.org/jira/browse/BEAM-12636
Project: Beam
Issue Type: Bug
Components: runner-dataflow, sdk-go
Affects Versions: 2.31.0
Reporter: Claudio Prates
Hi, I'm trying to run the example
[windowed_wordcount|https://github.com/apache/beam/blob/master/sdks/go/examples/windowed_wordcount/windowed_wordcount.go]
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
{code:java}
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
{code}
Also tried the with
{code:java}
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
{code}
Is this actually a bug or am I make some mistake running the example?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
