Details
-
Bug
-
Status: Resolved
-
P0
-
Resolution: Fixed
-
None
-
None
Description
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.
Attachments
Issue Links
- duplicates
-
BEAM-6723 Reshuffle in streaming pipeline does not work on dataflowrunner python
- Resolved
- links to