[jira] [Updated] (BEAM-12636) Windowing transform not working for sdk-go on Dataflow?

["Robert Burke (Jira)" <ji...@apache.org>]

     [ 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)