udim commented on a change in pull request #15605:
URL: https://github.com/apache/beam/pull/15605#discussion_r717833657
##########
File path: sdks/python/apache_beam/transforms/core.py
##########
@@ -2320,10 +2320,10 @@ def expand(self, pcoll):
if pcoll.pipeline.allow_unsafe_triggers:
# TODO(BEAM-9487) Change comment for Beam 2.33
_LOGGER.warning(
- '%s: PCollection passed to GroupByKey is unbounded, has a global '
- 'window, and uses a default trigger. This is being allowed '
- 'because --allow_unsafe_triggers is set, but it may prevent '
- 'data from making it through the pipeline.',
+ 'PCollection passed to GroupByKey (label: %s) is unbounded, has a '
+ 'global window, and uses a default trigger. This will no longer '
+ 'be allowed starting with Beam 2.33 unless '
Review comment:
or 2.34.0 to be precise :)
--
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]
