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)

Reply via email to