This is an automated email from the ASF dual-hosted git repository.

zhuzh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit feb5f9267067e549ee40efd691ae756338cc2e0b
Author: sunxia <xingbe...@gmail.com>
AuthorDate: Tue Jan 9 18:54:10 2024 +0800

    [hotfix] Remove redundant lazy initialization of 
LazyInitializedCoordinatorContext.
---
 .../flink/runtime/operators/coordination/OperatorCoordinatorHolder.java  | 1 -
 1 file changed, 1 deletion(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java
index a8ddf937de2..ec7e35bc066 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java
@@ -149,7 +149,6 @@ public class OperatorCoordinatorHolder
 
         this.globalFailureHandler = globalFailureHandler;
         this.mainThreadExecutor = mainThreadExecutor;
-        context.lazyInitialize(globalFailureHandler, mainThreadExecutor, 
checkpointCoordinator);
 
         context.lazyInitialize(globalFailureHandler, mainThreadExecutor, 
checkpointCoordinator);
         setupAllSubtaskGateways();

Reply via email to