[FLINK-33316] Avoid unnecessary heavy getStreamOperatorFactory

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.17.0, 1.18.0
• Fix Version/s: 1.17.2, 1.19.0, 1.18.1
• Component/s: Runtime / Configuration
• Labels: pull-request-available
• Assignee: Rui Fan
• Reporter: Rui Fan
• Created: 19/Oct/23 08:44
• Updated: 26/Oct/23 13:31
• Resolved: 19/Oct/23 12:41

Description

See FLINK-33315 for details.

This Jira focus on avoid unnecessary heavy getStreamOperatorFactory, it can optimize the memory and cpu cost of Replica_2 in FLINK-33315.

Solution: We can store the serializedUdfClassName at StreamConfig, and using the getStreamOperatorFactoryClassName instead of the heavy getStreamOperatorFactory in OperatorChain#getOperatorRecordsOutCounter.

Issue Links

• links to: GitHub Pull Request #23550
• links to: GitHub Pull Request #23597