diff --git a/sdks/python/apache_beam/transforms/core.py b/sdks/python/apache_beam/transforms/core.py index 54913c6ef3f8..dc706e129197 100644 --- a/sdks/python/apache_beam/transforms/core.py +++ b/sdks/python/apache_beam/transforms/core.py @@ -2474,18 +2474,14 @@ def typed(transform): # Capture in closure (avoiding capturing self). args, kwargs = self.args, self.kwargs - #TODO: This is a short term fix but CombineGlobally() needs a more - # thorough effort to ensure it works with multi-window inputs consistently + #TODO: We need to add support for multi-window inputs to CombineGlobally() def inject_default(_, combined): if combined: if len(combined) > 1: - _LOGGER.warning( - "Multiple simultaneous windows" - "aren't fully supported for CombineGlobally()") - fully_combined = [] - for element in combined: - fully_combined.append(element) - return fully_combined + raise ValueError( + "Input from multiple simultaneous windows" + "isn't currently supported for CombineGlobally()") + return combined[0] else: try: combine_fn.setup(*args, **kwargs)