Uses of Interface
org.apache.flink.runtime.concurrent.ComponentMainThreadExecutor

Packages that use ComponentMainThreadExecutor

Package	Description
org.apache.flink.runtime.blocklist
org.apache.flink.runtime.concurrent
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.dispatcher.cleanup
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.executiongraph.failover
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.jobmaster.slotpool
org.apache.flink.runtime.operators.coordination
org.apache.flink.runtime.rpc
org.apache.flink.runtime.scheduler
org.apache.flink.runtime.scheduler.adaptive
org.apache.flink.runtime.scheduler.adaptivebatch
org.apache.flink.runtime.scheduler.slowtaskdetector
org.apache.flink.runtime.scheduler.stopwithsavepoint
org.apache.flink.runtime.taskexecutor.slot

Uses of ComponentMainThreadExecutor in org.apache.flink.runtime.blocklist

Methods in org.apache.flink.runtime.blocklist with parameters of type ComponentMainThreadExecutor

Modifier and Type	Method and Description
BlocklistHandler	NoOpBlocklistHandler.Factory.create(BlocklistContext blocklistContext, Function<ResourceID,String> taskManagerNodeIdRetriever, ComponentMainThreadExecutor mainThreadExecutor, org.slf4j.Logger log)
BlocklistHandler	DefaultBlocklistHandler.Factory.create(BlocklistContext blocklistContext, Function<ResourceID,String> taskManagerNodeIdRetriever, ComponentMainThreadExecutor mainThreadExecutor, org.slf4j.Logger log)
BlocklistHandler	BlocklistHandler.Factory.create(BlocklistContext blocklistContext, Function<ResourceID,String> taskManagerNodeIdRetriever, ComponentMainThreadExecutor mainThreadExecutor, org.slf4j.Logger log) Instantiates a BlocklistHandler.

Uses of ComponentMainThreadExecutor in org.apache.flink.runtime.concurrent

Classes in org.apache.flink.runtime.concurrent that implement ComponentMainThreadExecutor

Modifier and Type	Class and Description
static class	ComponentMainThreadExecutor.DummyComponentMainThreadExecutor Dummy implementation of ComponentMainThreadExecutor.

Uses of ComponentMainThreadExecutor in org.apache.flink.runtime.dispatcher

Constructors in org.apache.flink.runtime.dispatcher with parameters of type ComponentMainThreadExecutor

Constructor and Description
OnMainThreadJobManagerRunnerRegistry(JobManagerRunnerRegistry delegate, ComponentMainThreadExecutor mainThreadExecutor)

Uses of ComponentMainThreadExecutor in org.apache.flink.runtime.dispatcher.cleanup

Methods in org.apache.flink.runtime.dispatcher.cleanup with parameters of type ComponentMainThreadExecutor

Modifier and Type	Method and Description
ResourceCleaner	DispatcherResourceCleanerFactory.createGlobalResourceCleaner(ComponentMainThreadExecutor mainThreadExecutor)
ResourceCleaner	ResourceCleanerFactory.createGlobalResourceCleaner(ComponentMainThreadExecutor mainThreadExecutor) Creates ResourceCleaner that initiates GloballyCleanableResource.globalCleanupAsync(JobID, Executor) calls.
ResourceCleaner	DispatcherResourceCleanerFactory.createLocalResourceCleaner(ComponentMainThreadExecutor mainThreadExecutor)
ResourceCleaner	ResourceCleanerFactory.createLocalResourceCleaner(ComponentMainThreadExecutor mainThreadExecutor) Creates ResourceCleaner that initiates LocallyCleanableResource.localCleanupAsync(JobID, Executor) calls.
static DefaultResourceCleaner.Builder<GloballyCleanableResource>	DefaultResourceCleaner.forGloballyCleanableResources(ComponentMainThreadExecutor mainThreadExecutor, Executor cleanupExecutor, RetryStrategy retryStrategy)
static DefaultResourceCleaner.Builder<LocallyCleanableResource>	DefaultResourceCleaner.forLocallyCleanableResources(ComponentMainThreadExecutor mainThreadExecutor, Executor cleanupExecutor, RetryStrategy retryStrategy)

Uses of ComponentMainThreadExecutor in org.apache.flink.runtime.executiongraph

Methods in org.apache.flink.runtime.executiongraph that return ComponentMainThreadExecutor

Modifier and Type	Method and Description
ComponentMainThreadExecutor	DefaultExecutionGraph.getJobMasterMainThreadExecutor()
ComponentMainThreadExecutor	ExecutionGraph.getJobMasterMainThreadExecutor()
ComponentMainThreadExecutor	InternalExecutionGraphAccessor.getJobMasterMainThreadExecutor()

Methods in org.apache.flink.runtime.executiongraph with parameters of type ComponentMainThreadExecutor

Modifier and Type	Method and Description
void	DefaultExecutionGraph.start(ComponentMainThreadExecutor jobMasterMainThreadExecutor)
void	ExecutionGraph.start(ComponentMainThreadExecutor jobMasterMainThreadExecutor)

Uses of ComponentMainThreadExecutor in org.apache.flink.runtime.executiongraph.failover

Constructors in org.apache.flink.runtime.executiongraph.failover with parameters of type ComponentMainThreadExecutor

Constructor and Description

ExecutionFailureHandler(Configuration jobMasterConfig, SchedulingTopology schedulingTopology, FailoverStrategy failoverStrategy, RestartBackoffTimeStrategy restartBackoffTimeStrategy, ComponentMainThreadExecutor mainThreadExecutor, Collection<FailureEnricher> failureEnrichers, FailureEnricher.Context taskFailureCtx, FailureEnricher.Context globalFailureCtx, MetricGroup metricGroup) Creates the handler to deal with task failures.

Uses of ComponentMainThreadExecutor in org.apache.flink.runtime.jobmaster

Methods in org.apache.flink.runtime.jobmaster with parameters of type ComponentMainThreadExecutor

Modifier and Type	Method and Description
SchedulerNG	DefaultSlotPoolServiceSchedulerFactory.createScheduler(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration configuration, SlotPoolService slotPoolService, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, BlocklistOperations blocklistOperations)
SchedulerNG	SlotPoolServiceSchedulerFactory.createScheduler(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration configuration, SlotPoolService slotPoolService, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, BlocklistOperations blocklistOperations) Creates a SchedulerNG.

Uses of ComponentMainThreadExecutor in org.apache.flink.runtime.jobmaster.slotpool

Methods in org.apache.flink.runtime.jobmaster.slotpool with parameters of type ComponentMainThreadExecutor

Modifier and Type	Method and Description
protected void	DeclarativeSlotPoolService.onStart(ComponentMainThreadExecutor componentMainThreadExecutor) This method is called when the slot pool service is started.
protected void	DeclarativeSlotPoolBridge.onStart(ComponentMainThreadExecutor componentMainThreadExecutor)
void	PhysicalSlotRequestBulkCheckerImpl.start(ComponentMainThreadExecutor mainThreadExecutor)
void	PhysicalSlotRequestBulkChecker.start(ComponentMainThreadExecutor mainThreadExecutor) Starts the bulk checker by initializing the main thread executor.
void	SlotPool.start(JobMasterId jobMasterId, String newJobManagerAddress, ComponentMainThreadExecutor jmMainThreadScheduledExecutor)
void	DeclarativeSlotPoolService.start(JobMasterId jobMasterId, String address, ComponentMainThreadExecutor mainThreadExecutor)
void	SlotPoolService.start(JobMasterId jobMasterId, String address, ComponentMainThreadExecutor mainThreadExecutor) Start the encapsulated slot pool implementation.

Uses of ComponentMainThreadExecutor in org.apache.flink.runtime.operators.coordination

Methods in org.apache.flink.runtime.operators.coordination with parameters of type ComponentMainThreadExecutor

Modifier and Type	Method and Description
void	OperatorCoordinatorHolder.lazyInitialize(GlobalFailureHandler globalFailureHandler, ComponentMainThreadExecutor mainThreadExecutor, CheckpointCoordinator checkpointCoordinator)
void	OperatorCoordinatorHolder.lazyInitialize(GlobalFailureHandler globalFailureHandler, ComponentMainThreadExecutor mainThreadExecutor, CheckpointCoordinator checkpointCoordinator, int operatorParallelism)

Uses of ComponentMainThreadExecutor in org.apache.flink.runtime.rpc

Classes in org.apache.flink.runtime.rpc that implement ComponentMainThreadExecutor

Modifier and Type	Class and Description
protected static class	RpcEndpoint.MainThreadExecutor Executor which executes runnables in the main thread context.

Uses of ComponentMainThreadExecutor in org.apache.flink.runtime.scheduler

Methods in org.apache.flink.runtime.scheduler that return ComponentMainThreadExecutor

Modifier and Type	Method and Description
protected ComponentMainThreadExecutor	SchedulerBase.getMainThreadExecutor()

Methods in org.apache.flink.runtime.scheduler with parameters of type ComponentMainThreadExecutor

Modifier and Type	Method and Description
DefaultExecutionDeployer	DefaultExecutionDeployer.Factory.createInstance(org.slf4j.Logger log, ExecutionSlotAllocator executionSlotAllocator, ExecutionOperations executionOperations, ExecutionVertexVersioner executionVertexVersioner, Time partitionRegistrationTimeout, BiConsumer<ExecutionVertexID,AllocationID> allocationReservationFunc, ComponentMainThreadExecutor mainThreadExecutor)
ExecutionDeployer	ExecutionDeployer.Factory.createInstance(org.slf4j.Logger log, ExecutionSlotAllocator executionSlotAllocator, ExecutionOperations executionOperations, ExecutionVertexVersioner executionVertexVersioner, Time partitionRegistrationTimeout, BiConsumer<ExecutionVertexID,AllocationID> allocationReservationFunc, ComponentMainThreadExecutor mainThreadExecutor) Instantiate an ExecutionDeployer with the given params.
SchedulerNG	SchedulerNGFactory.createInstance(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration jobMasterConfiguration, SlotPoolService slotPoolService, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, BlocklistOperations blocklistOperations)
SchedulerNG	DefaultSchedulerFactory.createInstance(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration jobMasterConfiguration, SlotPoolService slotPoolService, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, BlocklistOperations blocklistOperations)
void	DefaultOperatorCoordinatorHandler.initializeOperatorCoordinators(ComponentMainThreadExecutor mainThreadExecutor)
void	OperatorCoordinatorHandler.initializeOperatorCoordinators(ComponentMainThreadExecutor mainThreadExecutor) Initialize operator coordinators.
void	DefaultOperatorCoordinatorHandler.registerAndStartNewCoordinators(Collection<OperatorCoordinatorHolder> coordinators, ComponentMainThreadExecutor mainThreadExecutor, int parallelism)
void	OperatorCoordinatorHandler.registerAndStartNewCoordinators(Collection<OperatorCoordinatorHolder> coordinators, ComponentMainThreadExecutor mainThreadExecutor, int parallelism) Register and start new operator coordinators.

Constructors in org.apache.flink.runtime.scheduler with parameters of type ComponentMainThreadExecutor

Constructor and Description
DefaultScheduler(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration jobMasterConfiguration, Consumer<ComponentMainThreadExecutor> startUpAction, ScheduledExecutor delayExecutor, ClassLoader userCodeLoader, CheckpointsCleaner checkpointsCleaner, CheckpointRecoveryFactory checkpointRecoveryFactory, JobManagerJobMetricGroup jobManagerJobMetricGroup, SchedulingStrategyFactory schedulingStrategyFactory, FailoverStrategy.Factory failoverStrategyFactory, RestartBackoffTimeStrategy restartBackoffTimeStrategy, ExecutionOperations executionOperations, ExecutionVertexVersioner executionVertexVersioner, ExecutionSlotAllocatorFactory executionSlotAllocatorFactory, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, ExecutionGraphFactory executionGraphFactory, ShuffleMaster<?> shuffleMaster, Time rpcTimeout, VertexParallelismStore vertexParallelismStore, ExecutionDeployer.Factory executionDeployerFactory)
ExecutionGraphHandler(ExecutionGraph executionGraph, org.slf4j.Logger log, Executor ioExecutor, ComponentMainThreadExecutor mainThreadExecutor)
SchedulerBase(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration jobMasterConfiguration, CheckpointsCleaner checkpointsCleaner, CheckpointRecoveryFactory checkpointRecoveryFactory, JobManagerJobMetricGroup jobManagerJobMetricGroup, ExecutionVertexVersioner executionVertexVersioner, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, JobStatusListener jobStatusListener, ExecutionGraphFactory executionGraphFactory, VertexParallelismStore vertexParallelismStore)

Constructor parameters in org.apache.flink.runtime.scheduler with type arguments of type ComponentMainThreadExecutor

Constructor and Description

DefaultScheduler(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration jobMasterConfiguration, Consumer<ComponentMainThreadExecutor> startUpAction, ScheduledExecutor delayExecutor, ClassLoader userCodeLoader, CheckpointsCleaner checkpointsCleaner, CheckpointRecoveryFactory checkpointRecoveryFactory, JobManagerJobMetricGroup jobManagerJobMetricGroup, SchedulingStrategyFactory schedulingStrategyFactory, FailoverStrategy.Factory failoverStrategyFactory, RestartBackoffTimeStrategy restartBackoffTimeStrategy, ExecutionOperations executionOperations, ExecutionVertexVersioner executionVertexVersioner, ExecutionSlotAllocatorFactory executionSlotAllocatorFactory, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, ExecutionGraphFactory executionGraphFactory, ShuffleMaster<?> shuffleMaster, Time rpcTimeout, VertexParallelismStore vertexParallelismStore, ExecutionDeployer.Factory executionDeployerFactory)

Uses of ComponentMainThreadExecutor in org.apache.flink.runtime.scheduler.adaptive

Methods in org.apache.flink.runtime.scheduler.adaptive that return ComponentMainThreadExecutor

Modifier and Type	Method and Description
ComponentMainThreadExecutor	AdaptiveScheduler.getMainThreadExecutor()

Methods in org.apache.flink.runtime.scheduler.adaptive with parameters of type ComponentMainThreadExecutor

Modifier and Type

Method and Description

SchedulerNG

AdaptiveSchedulerFactory.createInstance(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration jobMasterConfiguration, SlotPoolService slotPoolService, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, BlocklistOperations blocklistOperations)

Constructors in org.apache.flink.runtime.scheduler.adaptive with parameters of type ComponentMainThreadExecutor

Constructor and Description

AdaptiveScheduler(AdaptiveScheduler.Settings settings, JobGraph jobGraph, JobResourceRequirements jobResourceRequirements, Configuration configuration, DeclarativeSlotPool declarativeSlotPool, SlotAllocator slotAllocator, Executor ioExecutor, ClassLoader userCodeClassLoader, CheckpointsCleaner checkpointsCleaner, CheckpointRecoveryFactory checkpointRecoveryFactory, JobManagerJobMetricGroup jobManagerJobMetricGroup, RestartBackoffTimeStrategy restartBackoffTimeStrategy, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, ExecutionGraphFactory executionGraphFactory)

Uses of ComponentMainThreadExecutor in org.apache.flink.runtime.scheduler.adaptivebatch

Methods in org.apache.flink.runtime.scheduler.adaptivebatch that return ComponentMainThreadExecutor

Modifier and Type	Method and Description
ComponentMainThreadExecutor	BatchJobRecoveryContext.getMainThreadExecutor() Provides the main thread executor.

Methods in org.apache.flink.runtime.scheduler.adaptivebatch with parameters of type ComponentMainThreadExecutor

Modifier and Type	Method and Description
SchedulerNG	AdaptiveBatchSchedulerFactory.createInstance(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration jobMasterConfiguration, SlotPoolService slotPoolService, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, BlocklistOperations blocklistOperations)
static AdaptiveBatchScheduler	AdaptiveBatchSchedulerFactory.createScheduler(org.slf4j.Logger log, JobGraph jobGraph, ExecutionConfig executionConfig, Executor ioExecutor, Configuration jobMasterConfiguration, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, BlocklistOperations blocklistOperations, ExecutionOperations executionOperations, ExecutionSlotAllocatorFactory allocatorFactory, RestartBackoffTimeStrategy restartBackoffTimeStrategy, ScheduledExecutor delayExecutor, VertexParallelismAndInputInfosDecider vertexParallelismAndInputInfosDecider, BatchJobRecoveryHandler jobRecoveryHandler)
void	DummySpeculativeExecutionHandler.init(ExecutionGraph executionGraph, ComponentMainThreadExecutor mainThreadExecutor, MetricGroup metricGroup)
void	SpeculativeExecutionHandler.init(ExecutionGraph executionGraph, ComponentMainThreadExecutor mainThreadExecutor, MetricGroup metricGroup) Initial speculative execution handler.
void	DefaultSpeculativeExecutionHandler.init(ExecutionGraph executionGraph, ComponentMainThreadExecutor mainThreadExecutor, MetricGroup metricGroup)

Constructors in org.apache.flink.runtime.scheduler.adaptivebatch with parameters of type ComponentMainThreadExecutor

Constructor and Description

AdaptiveBatchScheduler(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration jobMasterConfiguration, Consumer<ComponentMainThreadExecutor> startUpAction, ScheduledExecutor delayExecutor, ClassLoader userCodeLoader, CheckpointsCleaner checkpointsCleaner, CheckpointRecoveryFactory checkpointRecoveryFactory, JobManagerJobMetricGroup jobManagerJobMetricGroup, SchedulingStrategyFactory schedulingStrategyFactory, FailoverStrategy.Factory failoverStrategyFactory, RestartBackoffTimeStrategy restartBackoffTimeStrategy, ExecutionOperations executionOperations, ExecutionVertexVersioner executionVertexVersioner, ExecutionSlotAllocatorFactory executionSlotAllocatorFactory, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, ExecutionGraphFactory executionGraphFactory, ShuffleMaster<?> shuffleMaster, Time rpcTimeout, VertexParallelismAndInputInfosDecider vertexParallelismAndInputInfosDecider, int defaultMaxParallelism, BlocklistOperations blocklistOperations, JobManagerOptions.HybridPartitionDataConsumeConstraint hybridPartitionDataConsumeConstraint, Map<JobVertexID,ForwardGroup> forwardGroupsByJobVertexId, BatchJobRecoveryHandler jobRecoveryHandler)

Constructor parameters in org.apache.flink.runtime.scheduler.adaptivebatch with type arguments of type ComponentMainThreadExecutor

Constructor and Description

AdaptiveBatchScheduler(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration jobMasterConfiguration, Consumer<ComponentMainThreadExecutor> startUpAction, ScheduledExecutor delayExecutor, ClassLoader userCodeLoader, CheckpointsCleaner checkpointsCleaner, CheckpointRecoveryFactory checkpointRecoveryFactory, JobManagerJobMetricGroup jobManagerJobMetricGroup, SchedulingStrategyFactory schedulingStrategyFactory, FailoverStrategy.Factory failoverStrategyFactory, RestartBackoffTimeStrategy restartBackoffTimeStrategy, ExecutionOperations executionOperations, ExecutionVertexVersioner executionVertexVersioner, ExecutionSlotAllocatorFactory executionSlotAllocatorFactory, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, ExecutionGraphFactory executionGraphFactory, ShuffleMaster<?> shuffleMaster, Time rpcTimeout, VertexParallelismAndInputInfosDecider vertexParallelismAndInputInfosDecider, int defaultMaxParallelism, BlocklistOperations blocklistOperations, JobManagerOptions.HybridPartitionDataConsumeConstraint hybridPartitionDataConsumeConstraint, Map<JobVertexID,ForwardGroup> forwardGroupsByJobVertexId, BatchJobRecoveryHandler jobRecoveryHandler)

Uses of ComponentMainThreadExecutor in org.apache.flink.runtime.scheduler.slowtaskdetector

Methods in org.apache.flink.runtime.scheduler.slowtaskdetector with parameters of type ComponentMainThreadExecutor

Modifier and Type	Method and Description
void	SlowTaskDetector.start(ExecutionGraph executionGraph, SlowTaskDetectorListener listener, ComponentMainThreadExecutor mainThreadExecutor) Start detecting slow tasks periodically.
void	ExecutionTimeBasedSlowTaskDetector.start(ExecutionGraph executionGraph, SlowTaskDetectorListener listener, ComponentMainThreadExecutor mainThreadExecutor)

Uses of ComponentMainThreadExecutor in org.apache.flink.runtime.scheduler.stopwithsavepoint

Methods in org.apache.flink.runtime.scheduler.stopwithsavepoint with parameters of type ComponentMainThreadExecutor

Modifier and Type	Method and Description
CompletableFuture<String>	StopWithSavepointTerminationManager.stopWithSavepoint(CompletableFuture<CompletedCheckpoint> completedSavepointFuture, CompletableFuture<Collection<ExecutionState>> terminatedExecutionStatesFuture, ComponentMainThreadExecutor mainThreadExecutor) Enforces the correct completion order of the passed CompletableFuture instances in accordance to the contract of StopWithSavepointTerminationHandler.

Uses of ComponentMainThreadExecutor in org.apache.flink.runtime.taskexecutor.slot

Methods in org.apache.flink.runtime.taskexecutor.slot with parameters of type ComponentMainThreadExecutor

Modifier and Type	Method and Description
void	TaskSlotTable.start(SlotActions initialSlotActions, ComponentMainThreadExecutor mainThreadExecutor) Start the task slot table with the given slot actions.
void	TaskSlotTableImpl.start(SlotActions initialSlotActions, ComponentMainThreadExecutor mainThreadExecutor)