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)

Reply via email to