[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
pc wang updated FLINK-25728:
----------------------------
Description:
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
> 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
>
> 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)
