shunping commented on code in PR #35862:
URL: https://github.com/apache/beam/pull/35862#discussion_r2276656565
##########
sdks/python/apache_beam/transforms/util.py:
##########
@@ -266,7 +267,9 @@ def collect_values(key, tagged_values):
]
| Flatten(pipeline=self.pipeline)
| GroupByKey()
- | MapTuple(collect_values))
+ | MapTuple(collect_values).with_input_types(
Review Comment:
Similar to #33932, it is possible to break some tests because we are
changing the coder for this particular step, from a universal pickled coder to
the actual coder for the element.
However, the impact radius will be much smaller than the previous PR, as
cogbk is used less often than Reshuffle.
--
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]
