Uses of Interface
org.apache.flink.runtime.blocklist.BlocklistHandler.Factory

Packages that use BlocklistHandler.Factory

Package	Description
org.apache.flink.runtime.blocklist
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.resourcemanager.active

Uses of BlocklistHandler.Factory in org.apache.flink.runtime.blocklist

Classes in org.apache.flink.runtime.blocklist that implement BlocklistHandler.Factory

Modifier and Type	Class and Description
static class	DefaultBlocklistHandler.Factory The factory to instantiate DefaultBlocklistHandler.
static class	NoOpBlocklistHandler.Factory The factory to instantiate NoOpBlocklistHandler.

Methods in org.apache.flink.runtime.blocklist that return BlocklistHandler.Factory

Modifier and Type	Method and Description
static BlocklistHandler.Factory	BlocklistUtils.loadBlocklistHandlerFactory(Configuration configuration)

Uses of BlocklistHandler.Factory in org.apache.flink.runtime.jobmaster

Constructors in org.apache.flink.runtime.jobmaster with parameters of type BlocklistHandler.Factory

Constructor and Description

JobMaster(RpcService rpcService, JobMasterId jobMasterId, JobMasterConfiguration jobMasterConfiguration, ResourceID resourceId, JobGraph jobGraph, HighAvailabilityServices highAvailabilityService, SlotPoolServiceSchedulerFactory slotPoolServiceSchedulerFactory, JobManagerSharedServices jobManagerSharedServices, HeartbeatServices heartbeatServices, JobManagerJobMetricGroupFactory jobMetricGroupFactory, OnCompletionActions jobCompletionActions, FatalErrorHandler fatalErrorHandler, ClassLoader userCodeLoader, ShuffleMaster<?> shuffleMaster, PartitionTrackerFactory partitionTrackerFactory, ExecutionDeploymentTracker executionDeploymentTracker, ExecutionDeploymentReconciler.Factory executionDeploymentReconcilerFactory, BlocklistHandler.Factory blocklistHandlerFactory, Collection<FailureEnricher> failureEnrichers, long initializationTimestamp)

Uses of BlocklistHandler.Factory in org.apache.flink.runtime.resourcemanager

Constructors in org.apache.flink.runtime.resourcemanager with parameters of type BlocklistHandler.Factory

Constructor and Description
ResourceManager(RpcService rpcService, UUID leaderSessionId, ResourceID resourceId, HeartbeatServices heartbeatServices, DelegationTokenManager delegationTokenManager, SlotManager slotManager, ResourceManagerPartitionTrackerFactory clusterPartitionTrackerFactory, BlocklistHandler.Factory blocklistHandlerFactory, JobLeaderIdService jobLeaderIdService, ClusterInformation clusterInformation, FatalErrorHandler fatalErrorHandler, ResourceManagerMetricGroup resourceManagerMetricGroup, Time rpcTimeout, Executor ioExecutor)
StandaloneResourceManager(RpcService rpcService, UUID leaderSessionId, ResourceID resourceId, HeartbeatServices heartbeatServices, DelegationTokenManager delegationTokenManager, SlotManager slotManager, ResourceManagerPartitionTrackerFactory clusterPartitionTrackerFactory, BlocklistHandler.Factory blocklistHandlerFactory, JobLeaderIdService jobLeaderIdService, ClusterInformation clusterInformation, FatalErrorHandler fatalErrorHandler, ResourceManagerMetricGroup resourceManagerMetricGroup, Time startupPeriodTime, Time rpcTimeout, Executor ioExecutor)

Uses of BlocklistHandler.Factory in org.apache.flink.runtime.resourcemanager.active

Constructors in org.apache.flink.runtime.resourcemanager.active with parameters of type BlocklistHandler.Factory

Constructor and Description

ActiveResourceManager(ResourceManagerDriver<WorkerType> resourceManagerDriver, Configuration flinkConfig, RpcService rpcService, UUID leaderSessionId, ResourceID resourceId, HeartbeatServices heartbeatServices, DelegationTokenManager delegationTokenManager, SlotManager slotManager, ResourceManagerPartitionTrackerFactory clusterPartitionTrackerFactory, BlocklistHandler.Factory blocklistHandlerFactory, JobLeaderIdService jobLeaderIdService, ClusterInformation clusterInformation, FatalErrorHandler fatalErrorHandler, ResourceManagerMetricGroup resourceManagerMetricGroup, ThresholdMeter startWorkerFailureRater, Duration retryInterval, Duration workerRegistrationTimeout, Duration previousWorkerRecoverTimeout, Executor ioExecutor)