Package | Description |
---|---|
org.apache.flink.yarn |
Modifier and Type | Method and Description |
---|---|
protected RegisteredYarnWorkerNode |
YarnFlinkResourceManager.workerStarted(ResourceID resourceID) |
Modifier and Type | Method and Description |
---|---|
protected Collection<RegisteredYarnWorkerNode> |
YarnFlinkResourceManager.reacceptRegisteredWorkers(Collection<ResourceID> toConsolidate) |
Modifier and Type | Method and Description |
---|---|
protected void |
YarnFlinkResourceManager.releaseStartedWorker(RegisteredYarnWorkerNode worker) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.