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();