[
https://issues.apache.org/jira/browse/FLINK-33317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783550#comment-17783550
]
Rui Fan commented on FLINK-33317:
---------------------------------
Merged master<1.19> via: c83792b0f3fb6ae18dfabd52a89dc42c074ee73c
> Add cleaning mechanism for StreamConfig#SERIALIZEDUDF
> -----------------------------------------------------
>
> Key: FLINK-33317
> URL: https://issues.apache.org/jira/browse/FLINK-33317
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Configuration
> Affects Versions: 1.17.0, 1.18.0
> Reporter: Rui Fan
> Assignee: Rui Fan
> Priority: Major
> Labels: pull-request-available
>
> See FLINK-33315 for details.
> This Jira focus on avoid unnecessary memory usage, it can optimize the memory
> cost of Replica_3 in FLINK-33315.
>
> Solution:
> * After getStreamOperatorFactory, the StreamConfig#SERIALIZEDUDF can be
> cleaned
> In general, we don't clean any configuration. However, the SERIALIZED_UDF may
> be very large when operator includes some large objects.
> {@link #getStreamOperatorFactory}
> is used to create a StreamOperator and usually only needs to be called once.
> Callers can clean it to reduce the memory after calling the \{@link
> #getStreamOperatorFactory}.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
