Package | Description |
---|---|
org.apache.flink.runtime.jobmaster.slotpool | |
org.apache.flink.runtime.taskexecutor | |
org.apache.flink.types |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<SerializableOptional<ResourceID>> |
SlotPoolGateway.failAllocation(AllocationID allocationID,
Exception cause)
Fails the slot with the given allocation id.
|
CompletableFuture<SerializableOptional<ResourceID>> |
SlotPool.failAllocation(AllocationID allocationID,
Exception cause)
Fail the specified allocation and release the corresponding slot if we have one.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<SerializableOptional<String>> |
TaskExecutorGateway.requestMetricQueryServiceAddress(Time timeout)
Returns the fully qualified address of Metric Query Service on the TaskManager.
|
CompletableFuture<SerializableOptional<String>> |
TaskExecutor.requestMetricQueryServiceAddress(Time timeout) |
Modifier and Type | Method and Description |
---|---|
static <T extends Serializable> |
SerializableOptional.empty() |
static <T extends Serializable> |
SerializableOptional.of(T value) |
static <T extends Serializable> |
SerializableOptional.ofNullable(T value) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.