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)