[
https://issues.apache.org/jira/browse/BEAM-12636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Burke updated BEAM-12636:
--------------------------------
Resolution: Information Provided
Status: Resolved (was: Triage Needed)
> 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
> Priority: P3
>
> 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.20.1#820001)
