[
https://issues.apache.org/jira/browse/BEAM-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15242246#comment-15242246
]
ASF GitHub Bot commented on BEAM-188:
-------------------------------------
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-beam/pull/181
> Merging WindowFn + GBK + Write => InvalidWindows throws
> UnsupportedOperationException
> -------------------------------------------------------------------------------------
>
> Key: BEAM-188
> URL: https://issues.apache.org/jira/browse/BEAM-188
> Project: Beam
> Issue Type: Bug
> Components: sdk-java-core
> Reporter: Kenneth Knowles
> Assignee: Daniel Halperin
>
> The {{Write}} transform performs {{outputWithTimestamp(..., Instant.now())}}
> in the {{finishBundle}} of one of the encapsulated {{ParDo}} transforms. This
> action causes the {{WindowFn}} to be invoked to assign a window to the output
> value. But a merging {{WindowFn}} such as {{Sessions}} will be replaced by
> {{InvalidWindows}} at the GBK where merging is performed, so this is destined
> to crash.
> It is almost certain that the window is not relevant, so we can quickly fix
> this by just windowing into the global window earlier and using vanilla
> {{output(...)}}.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
