[
https://issues.apache.org/jira/browse/BEAM-9436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17051980#comment-17051980
]
Etienne Chauchot commented on BEAM-9436:
----------------------------------------
Could not avoid materialization because ReduceFnRunner needs an
Iterable<WindowedValue<InputT>> but managed to avoid a flatmap step and memory
consumption with KV creation.
> Try to avoid elements list materialization in GBK
> -------------------------------------------------
>
> Key: BEAM-9436
> URL: https://issues.apache.org/jira/browse/BEAM-9436
> Project: Beam
> Issue Type: Improvement
> Components: runner-spark
> Reporter: Etienne Chauchot
> Assignee: Etienne Chauchot
> Priority: Major
> Labels: structured-streaming
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
