[
https://issues.apache.org/jira/browse/BEAM-7972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16926041#comment-16926041
]
Mark Liu commented on BEAM-7972:
--------------------------------
Is this issue on track for 2.16 release? (branch will be cut in 3 days) Shall
we move it to 2.17?
> Portable Python Reshuffle does not work 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
> Priority: Blocker
> Fix For: 2.16.0
>
> Time Spent: 4h 20m
> Remaining Estimate: 0h
>
> 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
(v8.3.2#803003)
