[ 
https://issues.apache.org/jira/browse/BEAM-11252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402852#comment-17402852
 ] 

Beam JIRA Bot commented on BEAM-11252:
--------------------------------------

This issue was marked "stale-P2" and has not received a public comment in 14 
days. It is now automatically moved to P3. If you are still affected by it, you 
can comment and move it back to P2.

> Writing to BigQuery raises a TypeError "GlobalWindow -> ._IntervalWindowBase"
> -----------------------------------------------------------------------------
>
>                 Key: BEAM-11252
>                 URL: https://issues.apache.org/jira/browse/BEAM-11252
>             Project: Beam
>          Issue Type: Bug
>          Components: io-py-gcp
>    Affects Versions: 2.24.0, 2.25.0, 2.26.0, 2.27.0, 2.28.0, 2.29.0
>            Reporter: Tudor Plugaru
>            Priority: P3
>              Labels: bigquery
>
> I have a pipeline that reads from a PubSub topic, does some transforms and 
> then writes to BigQuery. The exception message is this: {{Cannot convert 
> GlobalWindow to apache_beam.utils.windowed_value._IntervalWindowBase}}
> You can find the main part of the pipeline here 
> [https://gist.github.com/PlugaruT/4666406bd8792b7b196dc1519c8885a2]
> The first part is basically reading from Pub/Sub and then I apply this 
> PTranform.
> And here is the gigantic stack trace: 
> [https://gist.github.com/PlugaruT/52bf3834eec95fd5cc5779d3332e1433]
>  
> I've tried to downgrade to 2.24.0 version but this is still happening.
> Also, I can't reproduce the exception locally when I run the pipeline with 
> DirectRunner. It's happening only when running on Dataflow.
>  
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to