Package | Description |
---|---|
org.apache.flink.runtime.resourcemanager |
Modifier and Type | Method and Description |
---|---|
protected ActiveResourceManager.PendingWorkerNums |
ActiveResourceManager.notifyNewWorkerAllocated(WorkerResourceSpec workerResourceSpec,
ResourceID resourceID)
Notify that a worker with the given resource spec has been allocated.
|
protected ActiveResourceManager.PendingWorkerNums |
ActiveResourceManager.notifyNewWorkerAllocationFailed(WorkerResourceSpec workerResourceSpec)
Notify that allocation of a worker with the given resource spec has failed.
|
protected ActiveResourceManager.PendingWorkerNums |
ActiveResourceManager.notifyNewWorkerRequested(WorkerResourceSpec workerResourceSpec)
Notify that a worker with the given resource spec has been requested.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.