You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "pc wang (Jira)" <ji...@apache.org> on 2022/01/20 10:35:00 UTC

[jira] [Updated] (FLINK-25728) StreamMultipleInputProcessor holds mass CompletableFuture instances under certain scenario

     [ 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)