public class TerminatingOnInitializeEvent extends Object implements org.apache.flink.runtime.operators.coordination.OperatorEvent
HeadOperatorCoordinator
that the status has been terminating on startup so
that the coordinator would not emit CoordinatorCheckpointEvent
.public static final TerminatingOnInitializeEvent INSTANCE
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.