Ankur Goenka created BEAM-7972:
----------------------------------
Summary: Portable Python Reshuffle does not work with with
windowed pcollection
Key: BEAM-7972
URL: https://issues.apache.org/jira/browse/BEAM-7972
Project: Beam
Issue Type: Bug
Components: sdk-py-core
Reporter: Ankur Goenka
Assignee: Ankur Goenka
Streaming pipeline gets stuck when using Reshuffle with windowed pcollection.
The issue happen because of window function gets deserialized on java side
which is not possible and hence default to global window function and result
into window function mismatch later down the code.
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)