Rui Fan created FLINK-33316: ------------------------------- Summary: Avoid unnecessary heavy getStreamOperatorFactory Key: FLINK-33316 URL: https://issues.apache.org/jira/browse/FLINK-33316 Project: Flink Issue Type: Sub-task Components: Runtime / Configuration Affects Versions: 1.17.0, 1.18.0 Reporter: Rui Fan Assignee: Rui Fan
This Jira focus on avoid unnecessary heavy getStreamOperatorFactory, it can optimize the memory and cpu cost of Replica_3 in FLINK-33315. Solution: We can store the serializedUdfClassName at StreamConfig, and using the getStreamOperatorFactoryClassName instead of the heavy getStreamOperatorFactory in OperatorChain#getOperatorRecordsOutCounter. -- This message was sent by Atlassian Jira (v8.20.10#820010)