kennknowles commented on PR #22620:
URL: https://github.com/apache/beam/pull/22620#issuecomment-1247251523
> * Nevertheless, it also showed that the approach is somehow flawed. Some
bounded test cases simply cannot be forced into a streaming execution, e.g. any
GroupByKey will fail on the GlobalWindow if there's no trigger set.
In the Beam model, this condition is that a GroupByKey of an _unbounded_
PCollection in global window must have a trigger. But you can still have a
bounded PCollection in streaming mode.
So the summary is:
- forcing a run in streaming mode, but leaving bounded PCollections as
bounded is OK
- automatically making all PCollections unbounded is flawed (but still can
be useful to find bugs sometimes)
--
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]
