Xuannan Su created FLINK-32476:
----------------------------------
Summary: Support configuring object-reuse for internal operators
Key: FLINK-32476
URL: https://issues.apache.org/jira/browse/FLINK-32476
Project: Flink
Issue Type: New Feature
Components: Runtime / Task
Reporter: Xuannan Su
Currently, object reuse is disabled by default for streaming jobs in order to
prevent unexpected behavior. Object reuse becomes problematic when the upstream
operator stores its output while the downstream operator modifies the input.
However, many operators implemented by Flink, such as Flink SQL operators, do
not modify the input. This implies that it is safe to reuse the input object in
such cases. Therefore, we intend to enable object reuse specifically for
operators that do not modify the input.
As the first step, we will focus on the operators implemented within Flink. We
will create the FLIP to introduce the API that allows user-defined operators to
enable object reuse in the future.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
