[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481956#comment-17481956
]
pc wang commented on FLINK-25728:
-
Ok.
> Potential memory leaks in StreamMultipleInputProcessor
>
[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481944#comment-17481944
]
pc wang edited comment on FLINK-25728 at 1/25/22, 4:49 PM:
---
That's correct. A
[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481944#comment-17481944
]
pc wang edited comment on FLINK-25728 at 1/25/22, 4:40 PM:
---
That's correct. A
[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481944#comment-17481944
]
pc wang edited comment on FLINK-25728 at 1/25/22, 4:40 PM:
---
That's correct. A
[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481944#comment-17481944
]
pc wang edited comment on FLINK-25728 at 1/25/22, 4:40 PM:
---
That's correct. A
[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481944#comment-17481944
]
pc wang commented on FLINK-25728:
-
That's correct. A bunch *CompletableFuture* instances and
[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481944#comment-17481944
]
pc wang edited comment on FLINK-25728 at 1/25/22, 4:39 PM:
---
That's correct. A
[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481070#comment-17481070
]
pc wang edited comment on FLINK-25728 at 1/24/22, 1:09 PM:
---
I know. I'm using
[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481070#comment-17481070
]
pc wang commented on FLINK-25728:
-
I know. I'm using the *_flink-mirror_* repo to run some test on Azure
[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481008#comment-17481008
]
pc wang edited comment on FLINK-25728 at 1/24/22, 11:08 AM:
Hi
[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481008#comment-17481008
]
pc wang edited comment on FLINK-25728 at 1/24/22, 11:06 AM:
I'm working on a
[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481008#comment-17481008
]
pc wang commented on FLINK-25728:
-
By the way, I'm working on a fix for the issue. Currently, it's
[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481002#comment-17481002
]
pc wang edited comment on FLINK-25728 at 1/24/22, 10:54 AM:
Thanks.
You can
[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481002#comment-17481002
]
pc wang commented on FLINK-25728:
-
Thanks.
You could reproduce this issue using this [Test
[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480848#comment-17480848
]
pc wang commented on FLINK-25728:
-
[~gaoyunhaii] hello, could you please take a look at this issue?
[
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
[
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
[
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
[
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
>
[
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
[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479328#comment-17479328
]
pc wang edited comment on FLINK-25728 at 1/21/22, 3:40 AM:
---
The issue has the
[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479328#comment-17479328
]
pc wang edited comment on FLINK-25728 at 1/21/22, 3:39 AM:
---
The issue has the
[
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
>
[
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
>
[
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
[
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
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479328#comment-17479328
]
pc wang commented on FLINK-25728:
-
The issue has the same symptoms as FLINK-24300, beside the momery
[
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
[
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
[
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
[
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
[
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
[
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
[
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,
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
37 matches
Mail list logo
