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

["Claudio Prates (Jira)" <ji...@apache.org>]

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)