[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17323295#comment-17323295 ] Flink Jira Bot commented on FLINK-12351: This issue is assigned but has not received an update

[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181094#comment-17181094 ] Piotr Nowojski commented on FLINK-12351: Yes that's true. I was more worried about relaying on

[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181081#comment-17181081 ] Wenlong Lyu commented on FLINK-12351: - [~pnowojski] As I known, it is easy to get whether the op is

[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180345#comment-17180345 ] Piotr Nowojski commented on FLINK-12351: I think this is a valid concern. I'm not sure how much

[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180304#comment-17180304 ] Till Rohrmann commented on FLINK-12351: --- Thanks for reporting this issue [~wenlong.lwl]. Pulling

[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180209#comment-17180209 ] Wenlong Lyu commented on FLINK-12351: - Hi, [~jark][~trohrmann] I think we may need to fix this issue

[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829298#comment-16829298 ] Jark Wu commented on FLINK-12351: - [~rmetzger] Thanks for the reminder. > AsyncWaitOperator should

[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829245#comment-16829245 ] Robert Metzger commented on FLINK-12351: Hey [~jark], thanks a lot for opening a ticket in the

[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829072#comment-16829072 ] Till Rohrmann commented on FLINK-12351: --- Go ahead with fixing this problem [~jark]. >

[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16828869#comment-16828869 ] Jark Wu commented on FLINK-12351: - Hi [~aitozi], I think fix the bug in AsyncWaitOperator and enable

[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827861#comment-16827861 ] aitozi commented on FLINK-12351: Hi, [~jark] I checked the objectuse config in other operator just now.