ee07dazn opened a new issue, #26583: URL: https://github.com/apache/beam/issues/26583
### What happened? Take an unbounded pcollection Attach event timestamp and sliding window Per element, in order to find count of elements with same id over the last X hr/min/sec.. this will require CombinePerKey and CoGroupByKey at different stages Write the output of CoGroupByKey to GCS If I write the output to BQ, it works fine but with GCS, it gives the following error `ValueError: GroupByKey cannot be applied to an unbounded PCollection with global windowing and a default trigger` I am not even using a global window but instead a sliding window so this definitely seems like a bug. ### Issue Priority Priority: 3 (minor) ### Issue Components - [X] Component: Python SDK - [ ] Component: Java SDK - [ ] Component: Go SDK - [ ] Component: Typescript SDK - [ ] Component: IO connector - [ ] Component: Beam examples - [ ] Component: Beam playground - [ ] Component: Beam katas - [ ] Component: Website - [ ] Component: Spark Runner - [ ] Component: Flink Runner - [ ] Component: Samza Runner - [ ] Component: Twister2 Runner - [ ] Component: Hazelcast Jet Runner - [X] Component: Google Cloud Dataflow Runner -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
