[
https://issues.apache.org/jira/browse/FLINK-35025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845188#comment-17845188
]
Yunfeng Zhou commented on FLINK-35025:
--------------------------------------
Hi [~zakelly], I just noticed that the current implementation might not be able
to work correctly if object reuse is enabled, given that multiple StreamRecords
would be cached. We may need to force copy the streamRecord before
processElement(),like that in AsyncWaitOperator.
https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java#L246
> Wire AsyncExecutionController to AbstractStreamOperator
> -------------------------------------------------------
>
> Key: FLINK-35025
> URL: https://issues.apache.org/jira/browse/FLINK-35025
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Task
> Reporter: Yanfei Lei
> Assignee: Zakelly Lan
> Priority: Major
> Labels: pull-request-available
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
