Hang Ruan created FLINK-31268:
---------------------------------

             Summary: OperatorCoordinator.Context#metricGroup will return null 
when restore from a savepoint
                 Key: FLINK-31268
                 URL: https://issues.apache.org/jira/browse/FLINK-31268
             Project: Flink
          Issue Type: Improvement
          Components: Runtime / Metrics
            Reporter: Hang Ruan


The `metricGroup` is initialized lazily in the method 
`OperatorCoordinatorHandler#initializeOperatorCoordinators`.

This will cause the NullPointerException when we use it in the method like 
`Source#restoreEnumerator`, which will be invoked through 
`SchedulerBase#createAndRestoreExecutionGraph` before 
`OperatorCoordinatorHandler#initializeOperatorCoordinators` in class 
`SchedulerBase#<init>`.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to