[jira] [Commented] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481956#comment-17481956 ] pc wang commented on FLINK-25728: - Ok. > Potential memory leaks in StreamMultipleInput

[jira] [Comment Edited] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481944#comment-17481944 ] pc wang edited comment on FLINK-25728 at 1/25/22, 4:49 PM: --- Th

[jira] [Comment Edited] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481944#comment-17481944 ] pc wang edited comment on FLINK-25728 at 1/25/22, 4:40 PM: --- Th

[jira] [Comment Edited] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481944#comment-17481944 ] pc wang edited comment on FLINK-25728 at 1/25/22, 4:40 PM: --- Th

[jira] [Comment Edited] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481944#comment-17481944 ] pc wang edited comment on FLINK-25728 at 1/25/22, 4:40 PM: --- Th

[jira] [Commented] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481944#comment-17481944 ] pc wang commented on FLINK-25728: - That's correct. A bunch *CompletableFuture* instances

[jira] [Comment Edited] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481944#comment-17481944 ] pc wang edited comment on FLINK-25728 at 1/25/22, 4:39 PM: --- Th

[jira] [Comment Edited] (FLINK-25728) Protential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481070#comment-17481070 ] pc wang edited comment on FLINK-25728 at 1/24/22, 1:09 PM: --- I

[jira] [Commented] (FLINK-25728) Protential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481070#comment-17481070 ] pc wang commented on FLINK-25728: - I know. I'm using the *_flink-mirror_* repo to run so

[jira] [Comment Edited] (FLINK-25728) Protential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481008#comment-17481008 ] pc wang edited comment on FLINK-25728 at 1/24/22, 11:08 AM:

[jira] [Comment Edited] (FLINK-25728) Protential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481008#comment-17481008 ] pc wang edited comment on FLINK-25728 at 1/24/22, 11:06 AM:

[jira] [Commented] (FLINK-25728) Protential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481008#comment-17481008 ] pc wang commented on FLINK-25728: - By the way, I'm working on a fix for the issue. Curre

[jira] [Comment Edited] (FLINK-25728) Protential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481002#comment-17481002 ] pc wang edited comment on FLINK-25728 at 1/24/22, 10:54 AM:

[jira] [Commented] (FLINK-25728) Protential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481002#comment-17481002 ] pc wang commented on FLINK-25728: - Thanks. You could reproduce this issue using this [Te

[jira] [Commented] (FLINK-25728) Protential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480848#comment-17480848 ] pc wang commented on FLINK-25728: - [~gaoyunhaii] hello, could you please take a look at

[jira] [Updated] (FLINK-25728) Protential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pc wang updated FLINK-25728: Summary: Protential memory leaks in StreamMultipleInputProcessor (was: Protential memory leeks in StreamM

[jira] [Updated] (FLINK-25728) Protential memory leeks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pc wang updated FLINK-25728: Description: We have an application that contains a broadcast process stage. The none-broadcast input has

[jira] [Updated] (FLINK-25728) Protential memory leeks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pc wang updated FLINK-25728: Description: We have an application that contains a broadcast process stage. The none-broadcast input has

[jira] [Updated] (FLINK-25728) Protential memory leeks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pc wang updated FLINK-25728: Labels: pull-request-available (was: ) > Protential memory leeks in StreamMultipleInputProcessor > --

[jira] [Updated] (FLINK-25728) Protential memory leeks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pc wang updated FLINK-25728: Component/s: Runtime / Task (was: API / DataStream) > Protential memory leeks in Stre

[jira] [Comment Edited] (FLINK-25728) Protential memory leeks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479328#comment-17479328 ] pc wang edited comment on FLINK-25728 at 1/21/22, 3:40 AM: --- Th

[jira] [Comment Edited] (FLINK-25728) Protential memory leeks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479328#comment-17479328 ] pc wang edited comment on FLINK-25728 at 1/21/22, 3:39 AM: --- Th

[jira] [Updated] (FLINK-25728) Protential memory leeks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pc wang updated FLINK-25728: Affects Version/s: 1.15.0 > Protential memory leeks in StreamMultipleInputProcessor >

[jira] [Updated] (FLINK-25728) Protential memory leeks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pc wang updated FLINK-25728: Priority: Blocker (was: Major) > Protential memory leeks in StreamMultipleInputProcessor > --

[jira] [Updated] (FLINK-25728) Protential memory leeks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pc wang updated FLINK-25728: Summary: Protential memory leeks in StreamMultipleInputProcessor (was: StreamMultipleInputProcessor holds

[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: We have an application that contains a broadcast process stage. The none-broadcast input has

[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: We have an application that contains a broadcast process stage. The none-broadcast input has

[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: Attachment: flink-completablefuture-issue.tar.xz > StreamMultipleInputProcessor holds mass CompletableFutu

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17479328#comment-17479328 ] pc wang commented on FLINK-25728: - The issue has the same symptoms as FLINK-24300, besid

[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: We have an application that contains a broadcast process stage. The none-broadcast input has

[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: We have an application contains a broadcast process stage. The none-broadcast input has roug

[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: We have an application contains a broadcast process stage. The none-broadcast input has roug

[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: We have an application contains a broadcast process stage. The none-broadcast input has roug

[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: We have an application contains a broadcast process stage. The none-broadcast input has roug

[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: Attachment: image-2022-01-20-18-43-32-816.png > StreamMultipleInputProcessor holds mass CompletableFuture

[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, t

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

pc wang created FLINK-25728: --- Summary: StreamMultipleInputProcessor holds mass CompletableFuture instances under certain scenario Key: FLINK-25728 URL: https://issues.apache.org/jira/browse/FLINK-25728 Proj