[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
pc wang updated FLINK-25728:
----------------------------
Attachment: image-2022-01-20-18-43-32-816.png
> StreamMultipleInputProcessor holds mass CompletableFuture instances under
> certain scenario
> ------------------------------------------------------------------------------------------
>
> Key: FLINK-25728
> URL: https://issues.apache.org/jira/browse/FLINK-25728
> Project: Flink
> Issue Type: Bug
> Components: API / DataStream
> Affects Versions: 1.12.5, 1.13.5, 1.14.2
> Reporter: pc wang
> Priority: Major
> Attachments: image-2022-01-20-18-43-32-816.png
>
>
> Our application contains a broadcast process stream operator. After several
> hours running, the TaskManager will run out of heap memory and restart. We
> reviewed the application code without finding any relevent issue.
> We found that the runing to crash time is ra
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
