[
https://issues.apache.org/jira/browse/FLINK-19852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17236668#comment-17236668
]
Stephan Ewen commented on FLINK-19852:
--------------------------------------
Transferring the memory sounds reasonable here.
I would go for the simplest solution here, not necessarily for the most
long-term maintainable, because this code is not expected to be evolved too
much any more. DataStream is taking over more and more functionality from
DataSet.
> Managed memory released check can block IterativeTask
> -----------------------------------------------------
>
> Key: FLINK-19852
> URL: https://issues.apache.org/jira/browse/FLINK-19852
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Task
> Affects Versions: 1.11.0, 1.10.2, 1.12.0, 1.11.1, 1.11.2
> Reporter: shaomeng.wang
> Assignee: Roman Khachatryan
> Priority: Critical
> Attachments: image-2020-10-28-17-48-28-395.png,
> image-2020-10-28-17-48-48-583.png
>
>
> UnsafeMemoryBudget#reserveMemory, called on TempBarrier, needs time to wait
> on GC of all allocated/released managed memory at every iteration.
>
> stack:
> !image-2020-10-28-17-48-48-583.png!
> new TempBarrier in BatchTask
> !image-2020-10-28-17-48-28-395.png!
>
> These will be very slow than before.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
