Modifier and Type | Method and Description |
---|---|
Time |
RestartStrategies.FixedDelayRestartStrategyConfiguration.getDelayBetweenAttemptsInterval() |
Time |
RestartStrategies.FailureRateRestartStrategyConfiguration.getDelayBetweenAttemptsInterval() |
Time |
RestartStrategies.FailureRateRestartStrategyConfiguration.getFailureInterval() |
Time |
RestartStrategies.ExponentialDelayRestartStrategyConfiguration.getInitialBackoff() |
Time |
RestartStrategies.ExponentialDelayRestartStrategyConfiguration.getMaxBackoff() |
Time |
RestartStrategies.ExponentialDelayRestartStrategyConfiguration.getResetBackoffThreshold() |
Modifier and Type | Method and Description |
---|---|
static RestartStrategies.ExponentialDelayRestartStrategyConfiguration |
RestartStrategies.exponentialDelayRestart(Time initialBackoff,
Time maxBackoff,
double backoffMultiplier,
Time resetBackoffThreshold,
double jitterFactor)
Generates a ExponentialDelayRestartStrategyConfiguration.
|
static RestartStrategies.FailureRateRestartStrategyConfiguration |
RestartStrategies.failureRateRestart(int failureRate,
Time failureInterval,
Time delayInterval)
Generates a FailureRateRestartStrategyConfiguration.
|
static RestartStrategies.RestartStrategyConfiguration |
RestartStrategies.fixedDelayRestart(int restartAttempts,
Time delayInterval)
Generates a FixedDelayRestartStrategyConfiguration.
|
Constructor and Description |
---|
ExponentialDelayRestartStrategyConfiguration(Time initialBackoff,
Time maxBackoff,
double backoffMultiplier,
Time resetBackoffThreshold,
double jitterFactor) |
FailureRateRestartStrategyConfiguration(int maxFailureRate,
Time failureInterval,
Time delayBetweenAttemptsInterval) |
Modifier and Type | Method and Description |
---|---|
Time |
StateTtlConfig.getTtl() |
Modifier and Type | Method and Description |
---|---|
static StateTtlConfig.Builder |
StateTtlConfig.newBuilder(Time ttl) |
StateTtlConfig.Builder |
StateTtlConfig.Builder.setTtl(Time ttl)
Sets the ttl time.
|
Constructor and Description |
---|
Builder(Time ttl) |
Modifier and Type | Method and Description |
---|---|
static Time |
Time.days(long days)
Creates a new
Time that represents the given number of days. |
static Time |
Time.fromDuration(java.time.Duration duration)
Creates a new
Time that represents the number of milliseconds in the given duration. |
static Time |
Time.hours(long hours)
Creates a new
Time that represents the given number of hours. |
static Time |
Time.milliseconds(long milliseconds)
Creates a new
Time that represents the given number of milliseconds. |
static Time |
Time.minutes(long minutes)
Creates a new
Time that represents the given number of minutes. |
static Time |
Time.of(long size,
TimeUnit unit)
|
static Time |
Time.seconds(long seconds)
Creates a new
Time that represents the given number of seconds. |
Constructor and Description |
---|
EmbeddedJobClient(JobID jobId,
DispatcherGateway dispatcherGateway,
ScheduledExecutor retryExecutor,
Time rpcTimeout,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
static Time |
ConfigurationUtils.getStandaloneClusterStartupPeriodTime(Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
static Optional<Time> |
ConfigurationUtils.getSystemResourceMetricsProbingInterval(Configuration configuration) |
Constructor and Description |
---|
FileExecutionGraphInfoStore(File rootDir,
Time expirationTime,
int maximumCapacity,
long maximumCacheSizeBytes,
ScheduledExecutor scheduledExecutor,
org.apache.flink.shaded.guava30.com.google.common.base.Ticker ticker) |
MemoryExecutionGraphInfoStore(Time expirationTime,
int maximumCapacity,
ScheduledExecutor scheduledExecutor,
org.apache.flink.shaded.guava30.com.google.common.base.Ticker ticker) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
CheckpointResourcesCleanupRunner.cancel(Time timeout) |
CompletableFuture<ExecutionGraphInfo> |
CheckpointResourcesCleanupRunner.requestJob(Time timeout) |
CompletableFuture<JobDetails> |
CheckpointResourcesCleanupRunner.requestJobDetails(Time timeout) |
CompletableFuture<JobStatus> |
CheckpointResourcesCleanupRunner.requestJobStatus(Time timeout) |
Modifier and Type | Method and Description |
---|---|
static DefaultExecutionGraph |
DefaultExecutionGraphBuilder.buildGraph(JobGraph jobGraph,
Configuration jobManagerConfig,
ScheduledExecutorService futureExecutor,
Executor ioExecutor,
ClassLoader classLoader,
CompletedCheckpointStore completedCheckpointStore,
CheckpointsCleaner checkpointsCleaner,
CheckpointIDCounter checkpointIdCounter,
Time rpcTimeout,
BlobWriter blobWriter,
org.slf4j.Logger log,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker partitionTracker,
TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionLocationConstraint,
ExecutionDeploymentListener executionDeploymentListener,
ExecutionStateUpdateListener executionStateUpdateListener,
long initializationTimestamp,
VertexAttemptNumberStore vertexAttemptNumberStore,
VertexParallelismStore vertexParallelismStore,
java.util.function.Supplier<CheckpointStatsTracker> checkpointStatsTrackerFactory,
boolean isDynamicGraph,
ExecutionJobVertex.Factory executionJobVertexFactory) |
protected ExecutionVertex |
ExecutionJobVertex.createExecutionVertex(ExecutionJobVertex jobVertex,
int subTaskIndex,
IntermediateResult[] producedDataSets,
Time timeout,
long createTimestamp,
int executionHistorySizeLimit,
int initialAttemptCount) |
protected ExecutionVertex |
SpeculativeExecutionJobVertex.createExecutionVertex(ExecutionJobVertex jobVertex,
int subTaskIndex,
IntermediateResult[] producedDataSets,
Time timeout,
long createTimestamp,
int executionHistorySizeLimit,
int initialAttemptCount) |
protected void |
ExecutionJobVertex.initialize(int executionHistorySizeLimit,
Time timeout,
long createTimestamp,
SubtaskAttemptNumberStore initialAttemptCounts,
CoordinatorStore coordinatorStore) |
Constructor and Description |
---|
DefaultExecutionGraph(JobInformation jobInformation,
ScheduledExecutorService futureExecutor,
Executor ioExecutor,
Time rpcTimeout,
int executionHistorySizeLimit,
ClassLoader userClassLoader,
BlobWriter blobWriter,
PartitionGroupReleaseStrategy.Factory partitionGroupReleaseStrategyFactory,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker partitionTracker,
TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionLocationConstraint,
ExecutionDeploymentListener executionDeploymentListener,
ExecutionStateUpdateListener executionStateUpdateListener,
long initializationTimestamp,
VertexAttemptNumberStore initialAttemptCounts,
VertexParallelismStore vertexParallelismStore,
boolean isDynamic,
ExecutionJobVertex.Factory executionJobVertexFactory,
List<JobStatusHook> jobStatusHooks) |
Execution(Executor executor,
ExecutionVertex vertex,
int attemptNumber,
long startTimestamp,
Time rpcTimeout)
Creates a new Execution attempt.
|
ExecutionVertex(ExecutionJobVertex jobVertex,
int subTaskIndex,
IntermediateResult[] producedDataSets,
Time timeout,
long createTimestamp,
int executionHistorySizeLimit,
int initialAttemptCount)
Creates an ExecutionVertex.
|
SpeculativeExecutionVertex(ExecutionJobVertex jobVertex,
int subTaskIndex,
IntermediateResult[] producedDataSets,
Time timeout,
long createTimestamp,
int executionHistorySizeLimit,
int initialAttemptCount) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
TaskManagerGateway.cancelTask(ExecutionAttemptID executionAttemptID,
Time timeout)
Cancel the given task.
|
CompletableFuture<Acknowledge> |
TaskManagerGateway.freeSlot(AllocationID allocationId,
Throwable cause,
Time timeout)
Frees the slot with the given allocation ID.
|
CompletableFuture<Acknowledge> |
TaskManagerGateway.submitTask(TaskDeploymentDescriptor tdd,
Time timeout)
Submit a task to the task manager.
|
CompletableFuture<Acknowledge> |
TaskManagerGateway.updatePartitions(ExecutionAttemptID executionAttemptID,
Iterable<PartitionInfo> partitionInfos,
Time timeout)
Update the task where the given partitions can be found.
|
Modifier and Type | Method and Description |
---|---|
Time |
JobMasterConfiguration.getRpcTimeout() |
Time |
JobMasterConfiguration.getSlotRequestTimeout() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
JobMaster.cancel(Time timeout) |
CompletableFuture<Acknowledge> |
JobMasterGateway.cancel(Time timeout)
Cancels the currently executed job.
|
CompletableFuture<Acknowledge> |
JobMasterServiceLeadershipRunner.cancel(Time timeout) |
CompletableFuture<Acknowledge> |
JobManagerRunner.cancel(Time timeout)
Cancels the currently executed job.
|
CompletableFuture<Acknowledge> |
RpcTaskManagerGateway.cancelTask(ExecutionAttemptID executionAttemptID,
Time timeout) |
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,
BlocklistOperations blocklistOperations)
Creates a
SchedulerNG . |
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,
BlocklistOperations blocklistOperations) |
CompletableFuture<CoordinationResponse> |
JobMaster.deliverCoordinationRequestToCoordinator(OperatorID operatorId,
SerializedValue<CoordinationRequest> serializedRequest,
Time timeout) |
CompletableFuture<CoordinationResponse> |
JobMasterGateway.deliverCoordinationRequestToCoordinator(OperatorID operatorId,
SerializedValue<CoordinationRequest> serializedRequest,
Time timeout)
Deliver a coordination request to a specified coordinator and return the response.
|
CompletableFuture<Acknowledge> |
RpcTaskManagerGateway.freeSlot(AllocationID allocationId,
Throwable cause,
Time timeout) |
CompletableFuture<Collection<SlotOffer>> |
JobMaster.offerSlots(ResourceID taskManagerId,
Collection<SlotOffer> slots,
Time timeout) |
CompletableFuture<Collection<SlotOffer>> |
JobMasterGateway.offerSlots(ResourceID taskManagerId,
Collection<SlotOffer> slots,
Time timeout)
Offers the given slots to the job manager.
|
CompletableFuture<RegistrationResponse> |
JobMaster.registerTaskManager(JobID jobId,
TaskManagerRegistrationInformation taskManagerRegistrationInformation,
Time timeout) |
CompletableFuture<RegistrationResponse> |
JobMasterGateway.registerTaskManager(JobID jobId,
TaskManagerRegistrationInformation taskManagerRegistrationInformation,
Time timeout)
Registers the task manager at the job manager.
|
CompletableFuture<ExecutionGraphInfo> |
JobMaster.requestJob(Time timeout) |
CompletableFuture<ExecutionGraphInfo> |
JobMasterGateway.requestJob(Time timeout)
Requests the
ExecutionGraphInfo of the executed job. |
CompletableFuture<ExecutionGraphInfo> |
JobMasterServiceLeadershipRunner.requestJob(Time timeout) |
CompletableFuture<ExecutionGraphInfo> |
JobManagerRunner.requestJob(Time timeout)
Requests the
ExecutionGraphInfo of the executed job. |
CompletableFuture<JobDetails> |
JobMaster.requestJobDetails(Time timeout) |
CompletableFuture<JobDetails> |
JobMasterGateway.requestJobDetails(Time timeout)
Request the details of the executed job.
|
CompletableFuture<JobDetails> |
JobMasterServiceLeadershipRunner.requestJobDetails(Time timeout) |
CompletableFuture<JobDetails> |
JobManagerRunner.requestJobDetails(Time timeout)
Request the details of the executed job.
|
CompletableFuture<JobStatus> |
JobMaster.requestJobStatus(Time timeout) |
CompletableFuture<JobStatus> |
JobMasterGateway.requestJobStatus(Time timeout)
Requests the current job status.
|
CompletableFuture<JobStatus> |
JobMasterServiceLeadershipRunner.requestJobStatus(Time timeout) |
CompletableFuture<JobStatus> |
JobManagerRunner.requestJobStatus(Time timeout)
Requests the current job status.
|
CompletableFuture<String> |
JobMaster.stopWithSavepoint(String targetDirectory,
SavepointFormatType formatType,
boolean terminate,
Time timeout) |
CompletableFuture<String> |
JobMasterGateway.stopWithSavepoint(String targetDirectory,
SavepointFormatType formatType,
boolean terminate,
Time timeout)
Stops the job with a savepoint.
|
CompletableFuture<Acknowledge> |
RpcTaskManagerGateway.submitTask(TaskDeploymentDescriptor tdd,
Time timeout) |
CompletableFuture<CompletedCheckpoint> |
JobMaster.triggerCheckpoint(CheckpointType checkpointType,
Time timeout) |
CompletableFuture<CompletedCheckpoint> |
JobMasterGateway.triggerCheckpoint(CheckpointType checkpointType,
Time timeout)
Triggers taking a checkpoint of the executed job.
|
default CompletableFuture<String> |
JobMasterGateway.triggerCheckpoint(Time timeout)
Triggers taking a checkpoint of the executed job.
|
CompletableFuture<String> |
JobMaster.triggerSavepoint(String targetDirectory,
boolean cancelJob,
SavepointFormatType formatType,
Time timeout) |
CompletableFuture<String> |
JobMasterGateway.triggerSavepoint(String targetDirectory,
boolean cancelJob,
SavepointFormatType formatType,
Time timeout)
Triggers taking a savepoint of the executed job.
|
CompletableFuture<Acknowledge> |
RpcTaskManagerGateway.updatePartitions(ExecutionAttemptID executionAttemptID,
Iterable<PartitionInfo> partitionInfos,
Time timeout) |
Constructor and Description |
---|
JobMasterConfiguration(Time rpcTimeout,
Time slotRequestTimeout,
String tmpDirectory,
RetryingRegistrationConfiguration retryingRegistrationConfiguration,
Configuration configuration) |
Modifier and Type | Field and Description |
---|---|
protected Time |
AbstractSlotPoolServiceFactory.batchSlotTimeout |
protected Time |
AbstractSlotPoolServiceFactory.rpcTimeout |
protected Time |
AbstractSlotPoolServiceFactory.slotIdleTimeout |
Modifier and Type | Method and Description |
---|---|
DeclarativeSlotPool |
DefaultDeclarativeSlotPoolFactory.create(JobID jobId,
java.util.function.Consumer<? super Collection<ResourceRequirement>> notifyNewResourceRequirements,
Time idleSlotTimeout,
Time rpcTimeout) |
DeclarativeSlotPool |
BlocklistDeclarativeSlotPoolFactory.create(JobID jobId,
java.util.function.Consumer<? super Collection<ResourceRequirement>> notifyNewResourceRequirements,
Time idleSlotTimeout,
Time rpcTimeout) |
DeclarativeSlotPool |
DeclarativeSlotPoolFactory.create(JobID jobId,
java.util.function.Consumer<? super Collection<ResourceRequirement>> notifyNewResourceRequirements,
Time idleSlotTimeout,
Time rpcTimeout) |
CompletableFuture<PhysicalSlot> |
SlotPool.requestNewAllocatedSlot(SlotRequestId slotRequestId,
ResourceProfile resourceProfile,
Collection<AllocationID> preferredAllocations,
Time timeout)
Request the allocation of a new slot from the resource manager.
|
CompletableFuture<PhysicalSlot> |
DeclarativeSlotPoolBridge.requestNewAllocatedSlot(SlotRequestId slotRequestId,
ResourceProfile resourceProfile,
Collection<AllocationID> preferredAllocations,
Time timeout) |
default CompletableFuture<PhysicalSlot> |
SlotPool.requestNewAllocatedSlot(SlotRequestId slotRequestId,
ResourceProfile resourceProfile,
Time timeout)
Request the allocation of a new slot from the resource manager.
|
void |
PhysicalSlotRequestBulkChecker.schedulePendingRequestBulkTimeoutCheck(PhysicalSlotRequestBulk bulk,
Time timeout)
Starts tracking the fulfillability of a
PhysicalSlotRequestBulk with timeout. |
void |
PhysicalSlotRequestBulkCheckerImpl.schedulePendingRequestBulkTimeoutCheck(PhysicalSlotRequestBulk bulk,
Time timeout) |
Constructor and Description |
---|
AbstractSlotPoolServiceFactory(Clock clock,
Time rpcTimeout,
Time slotIdleTimeout,
Time batchSlotTimeout) |
DeclarativeSlotPoolBridge(JobID jobId,
DeclarativeSlotPoolFactory declarativeSlotPoolFactory,
Clock clock,
Time rpcTimeout,
Time idleSlotTimeout,
Time batchSlotTimeout,
RequestSlotMatchingStrategy requestSlotMatchingStrategy) |
DeclarativeSlotPoolBridgeServiceFactory(Clock clock,
Time rpcTimeout,
Time slotIdleTimeout,
Time batchSlotTimeout,
RequestSlotMatchingStrategy requestSlotMatchingStrategy) |
DeclarativeSlotPoolService(JobID jobId,
DeclarativeSlotPoolFactory declarativeSlotPoolFactory,
Clock clock,
Time idleSlotTimeout,
Time rpcTimeout) |
DeclarativeSlotPoolServiceFactory(Clock clock,
Time idleSlotTimeout,
Time rpcTimeout) |
DefaultDeclarativeSlotPool(JobID jobId,
AllocatedSlotPool slotPool,
java.util.function.Consumer<? super Collection<ResourceRequirement>> notifyNewResourceRequirements,
Time idleSlotTimeout,
Time rpcTimeout) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<MetricDumpSerialization.MetricSerializationResult> |
MetricQueryService.queryMetrics(Time timeout) |
Modifier and Type | Method and Description |
---|---|
static void |
SystemResourcesMetricsInitializer.instantiateSystemMetrics(MetricGroup metricGroup,
Time probeInterval) |
Modifier and Type | Method and Description |
---|---|
static ProcessMetricGroup |
MetricUtils.instantiateProcessMetricGroup(MetricRegistry metricRegistry,
String hostname,
Optional<Time> systemResourceProbeInterval) |
static Tuple2<TaskManagerMetricGroup,MetricGroup> |
MetricUtils.instantiateTaskManagerMetricGroup(MetricRegistry metricRegistry,
String hostName,
ResourceID resourceID,
Optional<Time> systemResourceProbeInterval) |
Constructor and Description |
---|
SystemResourcesCounter(Time probeInterval) |
Modifier and Type | Method and Description |
---|---|
Time |
ResourceManagerRuntimeServicesConfiguration.getJobTimeout() |
Constructor and Description |
---|
DefaultJobLeaderIdService(HighAvailabilityServices highAvailabilityServices,
ScheduledExecutor scheduledExecutor,
Time jobTimeout) |
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) |
ResourceManagerRuntimeServicesConfiguration(Time jobTimeout,
SlotManagerConfiguration slotManagerConfiguration,
boolean enableFineGrainedResourceManagement) |
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) |
Modifier and Type | Method and Description |
---|---|
Time |
SlotManagerConfiguration.getSlotRequestTimeout() |
Time |
SlotManagerConfiguration.getTaskManagerRequestTimeout() |
Time |
SlotManagerConfiguration.getTaskManagerTimeout() |
Constructor and Description |
---|
DefaultSlotStatusSyncer(Time taskManagerRequestTimeout) |
SlotManagerConfiguration(Time taskManagerRequestTimeout,
Time slotRequestTimeout,
Time taskManagerTimeout,
java.time.Duration requirementCheckDelay,
boolean waitResultConsumedBeforeRelease,
SlotMatchingStrategy slotMatchingStrategy,
WorkerResourceSpec defaultWorkerResourceSpec,
int numSlotsPerWorker,
int maxSlotNum,
CPUResource maxTotalCpu,
MemorySize maxTotalMem,
int redundantTaskManagerNum) |
Modifier and Type | Method and Description |
---|---|
void |
RestClient.shutdown(Time timeout) |
Modifier and Type | Field and Description |
---|---|
protected Time |
LeaderRetrievalHandler.timeout |
Modifier and Type | Method and Description |
---|---|
Time |
RestHandlerConfiguration.getTimeout() |
Constructor and Description |
---|
AbstractHandler(GatewayRetriever<? extends T> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
UntypedResponseMessageHeaders<R,M> untypedResponseMessageHeaders) |
AbstractRestHandler(GatewayRetriever<? extends T> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<R,P,M> messageHeaders) |
LeaderRetrievalHandler(GatewayRetriever<? extends T> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders) |
RestHandlerConfiguration(long refreshInterval,
int maxCheckpointStatisticCacheEntries,
Time timeout,
File webUiDir,
boolean webSubmitEnabled,
boolean webCancelEnabled) |
Constructor and Description |
---|
StatusHandler(GatewayRetriever<? extends T> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,AsynchronousOperationResult<V>,M> messageHeaders) |
TriggerHandler(GatewayRetriever<? extends T> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<B,TriggerResponse,M> messageHeaders) |
Constructor and Description |
---|
ClusterDataSetDeleteStatusHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders) |
ClusterDataSetDeleteTriggerHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever) |
ClusterDataSetListHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever) |
Modifier and Type | Method and Description |
---|---|
static AbstractRestHandler<?,?,?,?> |
JobVertexFlameGraphHandler.disabledHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders) |
Constructor and Description |
---|
ClientCoordinationHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<ClientCoordinationRequestBody,ClientCoordinationResponseBody,ClientCoordinationMessageParameters> messageHeaders) |
Constructor and Description |
---|
RescalingStatusHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders) |
RescalingTriggerHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders) |
Constructor and Description |
---|
SavepointDisposalStatusHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders) |
SavepointDisposalTriggerHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders) |
SavepointStatusHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders) |
SavepointTriggerHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders) |
StopWithSavepointHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders) |
Constructor and Description |
---|
DefaultExecutionGraphCache(Time timeout,
Time timeToLive) |
Constructor and Description |
---|
StaticFileServerHandler(GatewayRetriever<? extends T> retriever,
Time timeout,
File rootPath) |
Constructor and Description |
---|
MetricFetcherImpl(GatewayRetriever<T> retriever,
MetricQueryServiceRetriever queryServiceRetriever,
Executor executor,
Time timeout,
long updateInterval) |
Constructor and Description |
---|
AbstractResourceManagerHandler(GatewayRetriever<? extends T> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<R,P,M> messageHeaders,
GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever) |
Modifier and Type | Field and Description |
---|---|
static Time |
RpcUtils.INF_TIMEOUT
HACK: Set to 21474835 seconds, Akka's maximum delay (Akka 2.4.20).
|
Modifier and Type | Method and Description |
---|---|
DefaultExecutionDeployer |
DefaultExecutionDeployer.Factory.createInstance(org.slf4j.Logger log,
ExecutionSlotAllocator executionSlotAllocator,
ExecutionOperations executionOperations,
ExecutionVertexVersioner executionVertexVersioner,
Time partitionRegistrationTimeout,
java.util.function.BiConsumer<ExecutionVertexID,AllocationID> allocationReservationFunc,
ComponentMainThreadExecutor mainThreadExecutor) |
ExecutionDeployer |
ExecutionDeployer.Factory.createInstance(org.slf4j.Logger log,
ExecutionSlotAllocator executionSlotAllocator,
ExecutionOperations executionOperations,
ExecutionVertexVersioner executionVertexVersioner,
Time partitionRegistrationTimeout,
java.util.function.BiConsumer<ExecutionVertexID,AllocationID> allocationReservationFunc,
ComponentMainThreadExecutor mainThreadExecutor)
Instantiate an
ExecutionDeployer with the given params. |
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,
BlocklistOperations blocklistOperations) |
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,
BlocklistOperations blocklistOperations) |
Constructor and Description |
---|
DefaultExecutionGraphFactory(Configuration configuration,
ClassLoader userCodeClassLoader,
ExecutionDeploymentTracker executionDeploymentTracker,
ScheduledExecutorService futureExecutor,
Executor ioExecutor,
Time rpcTimeout,
JobManagerJobMetricGroup jobManagerJobMetricGroup,
BlobWriter blobWriter,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker jobMasterPartitionTracker) |
DefaultExecutionGraphFactory(Configuration configuration,
ClassLoader userCodeClassLoader,
ExecutionDeploymentTracker executionDeploymentTracker,
ScheduledExecutorService futureExecutor,
Executor ioExecutor,
Time rpcTimeout,
JobManagerJobMetricGroup jobManagerJobMetricGroup,
BlobWriter blobWriter,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker jobMasterPartitionTracker,
boolean isDynamicGraph,
ExecutionJobVertex.Factory executionJobVertexFactory) |
DefaultScheduler(org.slf4j.Logger log,
JobGraph jobGraph,
Executor ioExecutor,
Configuration jobMasterConfiguration,
java.util.function.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,
ExecutionGraphFactory executionGraphFactory,
ShuffleMaster<?> shuffleMaster,
Time rpcTimeout,
VertexParallelismStore vertexParallelismStore,
ExecutionDeployer.Factory executionDeployerFactory) |
SlotSharingExecutionSlotAllocatorFactory(PhysicalSlotProvider slotProvider,
boolean slotWillBeOccupiedIndefinitely,
PhysicalSlotRequestBulkChecker bulkChecker,
Time allocationTimeout) |
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,
BlocklistOperations blocklistOperations) |
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,
BlocklistOperations blocklistOperations) |
Constructor and Description |
---|
AdaptiveBatchScheduler(org.slf4j.Logger log,
JobGraph jobGraph,
Executor ioExecutor,
Configuration jobMasterConfiguration,
java.util.function.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,
ExecutionGraphFactory executionGraphFactory,
ShuffleMaster<?> shuffleMaster,
Time rpcTimeout,
VertexParallelismDecider vertexParallelismDecider,
int defaultMaxParallelism) |
SpeculativeScheduler(org.slf4j.Logger log,
JobGraph jobGraph,
Executor ioExecutor,
Configuration jobMasterConfiguration,
java.util.function.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,
ExecutionGraphFactory executionGraphFactory,
ShuffleMaster<?> shuffleMaster,
Time rpcTimeout,
VertexParallelismDecider vertexParallelismDecider,
int defaultMaxParallelism,
BlocklistOperations blocklistOperations) |
Modifier and Type | Method and Description |
---|---|
Time |
TaskManagerConfiguration.getRpcTimeout() |
Time |
TaskManagerConfiguration.getSlotTimeout() |
Modifier and Type | Method and Description |
---|---|
Optional<Time> |
TaskManagerServicesConfiguration.getSystemResourceMetricsProbingInterval() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
TaskExecutorGatewayDecoratorBase.cancelTask(ExecutionAttemptID executionAttemptID,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutor.cancelTask(ExecutionAttemptID executionAttemptID,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutorGateway.cancelTask(ExecutionAttemptID executionAttemptID,
Time timeout)
Cancel the given task.
|
void |
TaskExecutorGatewayDecoratorBase.freeInactiveSlots(JobID jobId,
Time timeout) |
void |
TaskExecutor.freeInactiveSlots(JobID jobId,
Time timeout) |
void |
TaskExecutorGateway.freeInactiveSlots(JobID jobId,
Time timeout)
Frees all currently inactive slot allocated for the given job.
|
CompletableFuture<Acknowledge> |
TaskExecutorGatewayDecoratorBase.freeSlot(AllocationID allocationId,
Throwable cause,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutor.freeSlot(AllocationID allocationId,
Throwable cause,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutorGateway.freeSlot(AllocationID allocationId,
Throwable cause,
Time timeout)
Frees the slot with the given allocation ID.
|
CompletableFuture<Acknowledge> |
TaskExecutorGatewayDecoratorBase.releaseClusterPartitions(Collection<IntermediateDataSetID> dataSetsToRelease,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutor.releaseClusterPartitions(Collection<IntermediateDataSetID> dataSetsToRelease,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutorGateway.releaseClusterPartitions(Collection<IntermediateDataSetID> dataSetsToRelease,
Time timeout)
Releases all cluster partitions belong to any of the given data sets.
|
CompletableFuture<TransientBlobKey> |
TaskExecutorGatewayDecoratorBase.requestFileUploadByName(String fileName,
Time timeout) |
CompletableFuture<TransientBlobKey> |
TaskExecutor.requestFileUploadByName(String fileName,
Time timeout) |
CompletableFuture<TransientBlobKey> |
TaskExecutorGateway.requestFileUploadByName(String fileName,
Time timeout)
Requests the file upload of the specified name to the cluster's
BlobServer . |
CompletableFuture<TransientBlobKey> |
TaskExecutorGatewayDecoratorBase.requestFileUploadByType(FileType fileType,
Time timeout) |
CompletableFuture<TransientBlobKey> |
TaskExecutor.requestFileUploadByType(FileType fileType,
Time timeout) |
CompletableFuture<TransientBlobKey> |
TaskExecutorGateway.requestFileUploadByType(FileType fileType,
Time timeout)
Requests the file upload of the specified type to the cluster's
BlobServer . |
CompletableFuture<Collection<LogInfo>> |
TaskExecutorGatewayDecoratorBase.requestLogList(Time timeout) |
CompletableFuture<Collection<LogInfo>> |
TaskExecutor.requestLogList(Time timeout) |
CompletableFuture<Collection<LogInfo>> |
TaskExecutorGateway.requestLogList(Time timeout)
Requests for the historical log file names on the TaskManager.
|
CompletableFuture<SerializableOptional<String>> |
TaskExecutorGatewayDecoratorBase.requestMetricQueryServiceAddress(Time timeout) |
CompletableFuture<SerializableOptional<String>> |
TaskExecutor.requestMetricQueryServiceAddress(Time timeout) |
CompletableFuture<SerializableOptional<String>> |
TaskExecutorGateway.requestMetricQueryServiceAddress(Time timeout)
Returns the gateway of Metric Query Service on the TaskManager.
|
CompletableFuture<Acknowledge> |
TaskExecutorGatewayDecoratorBase.requestSlot(SlotID slotId,
JobID jobId,
AllocationID allocationId,
ResourceProfile resourceProfile,
String targetAddress,
ResourceManagerId resourceManagerId,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutor.requestSlot(SlotID slotId,
JobID jobId,
AllocationID allocationId,
ResourceProfile resourceProfile,
String targetAddress,
ResourceManagerId resourceManagerId,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutorGateway.requestSlot(SlotID slotId,
JobID jobId,
AllocationID allocationId,
ResourceProfile resourceProfile,
String targetAddress,
ResourceManagerId resourceManagerId,
Time timeout)
Requests a slot from the TaskManager.
|
CompletableFuture<ThreadDumpInfo> |
TaskExecutorGatewayDecoratorBase.requestThreadDump(Time timeout) |
CompletableFuture<ThreadDumpInfo> |
TaskExecutor.requestThreadDump(Time timeout) |
CompletableFuture<ThreadDumpInfo> |
TaskExecutorGateway.requestThreadDump(Time timeout)
Requests the thread dump from this TaskManager.
|
CompletableFuture<TaskThreadInfoResponse> |
TaskExecutorGatewayDecoratorBase.requestThreadInfoSamples(Collection<ExecutionAttemptID> taskExecutionAttemptIds,
ThreadInfoSamplesRequest requestParams,
Time timeout) |
CompletableFuture<TaskThreadInfoResponse> |
TaskExecutor.requestThreadInfoSamples(Collection<ExecutionAttemptID> taskExecutionAttemptIds,
ThreadInfoSamplesRequest requestParams,
Time timeout) |
CompletableFuture<TaskThreadInfoResponse> |
TaskExecutorThreadInfoGateway.requestThreadInfoSamples(Collection<ExecutionAttemptID> taskExecutionAttemptIds,
ThreadInfoSamplesRequest requestParams,
Time timeout)
Request a thread info sample from the given tasks.
|
CompletableFuture<Acknowledge> |
TaskExecutorGatewayDecoratorBase.submitTask(TaskDeploymentDescriptor tdd,
JobMasterId jobMasterId,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutor.submitTask(TaskDeploymentDescriptor tdd,
JobMasterId jobMasterId,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutorGateway.submitTask(TaskDeploymentDescriptor tdd,
JobMasterId jobMasterId,
Time timeout)
Submit a
Task to the TaskExecutor . |
CompletableFuture<Acknowledge> |
TaskExecutorGatewayDecoratorBase.updatePartitions(ExecutionAttemptID executionAttemptID,
Iterable<PartitionInfo> partitionInfos,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutor.updatePartitions(ExecutionAttemptID executionAttemptID,
Iterable<PartitionInfo> partitionInfos,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutorGateway.updatePartitions(ExecutionAttemptID executionAttemptID,
Iterable<PartitionInfo> partitionInfos,
Time timeout)
Update the task where the given partitions can be found.
|
Constructor and Description |
---|
TaskManagerConfiguration(int numberSlots,
ResourceProfile defaultSlotResourceProfile,
ResourceProfile totalResourceProfile,
String[] tmpDirectories,
Time rpcTimeout,
Time slotTimeout,
java.time.Duration maxRegistrationDuration,
Configuration configuration,
boolean exitJvmOnOutOfMemory,
String taskManagerLogPath,
String taskManagerStdoutPath,
String taskManagerLogDir,
String taskManagerExternalAddress,
File tmpWorkingDirectory,
RetryingRegistrationConfiguration retryingRegistrationConfiguration) |
Constructor and Description |
---|
RpcInputSplitProvider(JobMasterGateway jobMasterGateway,
JobVertexID jobVertexID,
ExecutionAttemptID executionAttemptID,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
boolean |
TaskSlotTable.allocateSlot(int index,
JobID jobId,
AllocationID allocationId,
ResourceProfile resourceProfile,
Time slotTimeout)
Allocate the slot with the given index for the given job and allocation id.
|
boolean |
TaskSlotTableImpl.allocateSlot(int requestedIndex,
JobID jobId,
AllocationID allocationId,
ResourceProfile resourceProfile,
Time slotTimeout) |
boolean |
TaskSlotTable.allocateSlot(int index,
JobID jobId,
AllocationID allocationId,
Time slotTimeout)
Allocate the slot with the given index for the given job and allocation id.
|
boolean |
TaskSlotTableImpl.allocateSlot(int index,
JobID jobId,
AllocationID allocationId,
Time slotTimeout) |
boolean |
TaskSlotTable.markSlotInactive(AllocationID allocationId,
Time slotTimeout)
Marks the slot under the given allocation id as inactive.
|
boolean |
TaskSlotTableImpl.markSlotInactive(AllocationID allocationId,
Time slotTimeout) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
RestfulGateway.cancelJob(JobID jobId,
Time timeout)
Cancel the given job.
|
CompletableFuture<Acknowledge> |
NonLeaderRetrievalRestfulGateway.cancelJob(JobID jobId,
Time timeout) |
default CompletableFuture<CoordinationResponse> |
RestfulGateway.deliverCoordinationRequestToCoordinator(JobID jobId,
OperatorID operatorId,
SerializedValue<CoordinationRequest> serializedRequest,
Time timeout)
Deliver a coordination request to a specified coordinator and return the response.
|
default CompletableFuture<Acknowledge> |
RestfulGateway.disposeSavepoint(String savepointPath,
Time timeout)
Dispose the given savepoint.
|
static WebMonitorExtension |
WebMonitorUtils.loadWebSubmissionExtension(GatewayRetriever<? extends DispatcherGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
CompletableFuture<String> localAddressFuture,
Path uploadDir,
Executor executor,
Configuration configuration)
Loads the
WebMonitorExtension which enables web submission. |
CompletableFuture<ClusterOverview> |
RestfulGateway.requestClusterOverview(Time timeout)
Requests the cluster status overview.
|
CompletableFuture<ClusterOverview> |
NonLeaderRetrievalRestfulGateway.requestClusterOverview(Time timeout) |
CompletableFuture<ExecutionGraphInfo> |
RestfulGateway.requestExecutionGraphInfo(JobID jobId,
Time timeout)
Requests the
ExecutionGraphInfo containing additional information besides the ArchivedExecutionGraph . |
CompletableFuture<ExecutionGraphInfo> |
NonLeaderRetrievalRestfulGateway.requestExecutionGraphInfo(JobID jobId,
Time timeout) |
default CompletableFuture<ArchivedExecutionGraph> |
RestfulGateway.requestJob(JobID jobId,
Time timeout)
Requests the
ArchivedExecutionGraph for the given jobId. |
CompletableFuture<JobResult> |
RestfulGateway.requestJobResult(JobID jobId,
Time timeout)
Requests the
JobResult of a job specified by the given jobId. |
CompletableFuture<JobResult> |
NonLeaderRetrievalRestfulGateway.requestJobResult(JobID jobId,
Time timeout) |
default CompletableFuture<JobStatus> |
RestfulGateway.requestJobStatus(JobID jobId,
Time timeout)
Request the
JobStatus of the given job. |
CompletableFuture<Collection<String>> |
RestfulGateway.requestMetricQueryServiceAddresses(Time timeout)
Requests the addresses of the
MetricQueryService to query. |
CompletableFuture<Collection<String>> |
NonLeaderRetrievalRestfulGateway.requestMetricQueryServiceAddresses(Time timeout) |
CompletableFuture<MultipleJobsDetails> |
RestfulGateway.requestMultipleJobDetails(Time timeout)
Requests job details currently being executed on the Flink cluster.
|
CompletableFuture<MultipleJobsDetails> |
NonLeaderRetrievalRestfulGateway.requestMultipleJobDetails(Time timeout) |
CompletableFuture<Collection<Tuple2<ResourceID,String>>> |
RestfulGateway.requestTaskManagerMetricQueryServiceAddresses(Time timeout)
Requests the addresses for the TaskManagers'
MetricQueryService to query. |
CompletableFuture<Collection<Tuple2<ResourceID,String>>> |
NonLeaderRetrievalRestfulGateway.requestTaskManagerMetricQueryServiceAddresses(Time timeout) |
CompletableFuture<ThreadDumpInfo> |
RestfulGateway.requestThreadDump(Time timeout)
Requests the thread dump from the JobManager.
|
CompletableFuture<ThreadDumpInfo> |
NonLeaderRetrievalRestfulGateway.requestThreadDump(Time timeout) |
default CompletableFuture<Acknowledge> |
RestfulGateway.stopWithSavepoint(AsynchronousJobOperationKey operationKey,
String targetDirectory,
SavepointFormatType formatType,
TriggerSavepointMode savepointMode,
Time timeout)
Stops the job with a savepoint, returning a future that completes when the operation is
started.
|
default CompletableFuture<Acknowledge> |
RestfulGateway.triggerCheckpoint(AsynchronousJobOperationKey operationKey,
CheckpointType checkpointType,
Time timeout)
Triggers a checkpoint with the given savepoint directory as a target.
|
default CompletableFuture<Acknowledge> |
RestfulGateway.triggerSavepoint(AsynchronousJobOperationKey operationKey,
String targetDirectory,
SavepointFormatType formatType,
TriggerSavepointMode savepointMode,
Time timeout)
Triggers a savepoint with the given savepoint directory as a target, returning a future that
completes when the operation is started.
|
static <T extends RestfulGateway> |
WebMonitorUtils.tryLoadWebContent(GatewayRetriever<? extends T> leaderRetriever,
Time timeout,
File tmpDir)
Checks whether the flink-runtime-web dependency is available and if so returns a
StaticFileServerHandler which can serve the static file contents.
|
Constructor and Description |
---|
WebSubmissionExtension(Configuration configuration,
GatewayRetriever<? extends DispatcherGateway> leaderRetriever,
Map<String,String> responseHeaders,
CompletableFuture<String> localAddressFuture,
Path jarDir,
Executor executor,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<MetricDumpSerialization.MetricSerializationResult> |
MetricQueryServiceGateway.queryMetrics(Time timeout) |
Modifier and Type | Method and Description |
---|---|
static <T extends Statistics> |
JobVertexThreadInfoTrackerBuilder.newBuilder(GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever,
java.util.function.Function<JobVertexThreadInfoStats,T> createStatsFn,
ScheduledExecutorService executor,
Time restTimeout)
Create a new
JobVertexThreadInfoTrackerBuilder . |
Modifier and Type | Field and Description |
---|---|
static Time |
FlinkKafkaProducer.DEFAULT_KAFKA_TRANSACTION_TIMEOUT
Deprecated.
Default value for kafka transaction timeout.
|
Modifier and Type | Method and Description |
---|---|
void |
TableConfig.setIdleStateRetentionTime(Time minTime,
Time maxTime)
Deprecated.
use
TableConfig.setIdleStateRetention(Duration) instead. |
Modifier and Type | Method and Description |
---|---|
static java.time.Duration |
TimeUtils.toDuration(Time time)
Translates
Time to Duration . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.