Package | Description |
---|---|
org.apache.flink.runtime.blocklist | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.resourcemanager |
Modifier and Type | Method and Description |
---|---|
Collection<BlockedNode> |
DefaultBlocklistTracker.getAllBlockedNodes() |
Collection<BlockedNode> |
BlocklistTracker.getAllBlockedNodes()
Get all blocked nodes.
|
Collection<BlockedNode> |
DefaultBlocklistTracker.removeTimeoutNodes(long currentTimestamp) |
Collection<BlockedNode> |
BlocklistTracker.removeTimeoutNodes(long currentTimeMillis)
Remove timeout nodes.
|
Modifier and Type | Method and Description |
---|---|
void |
NoOpBlocklistHandler.addNewBlockedNodes(Collection<BlockedNode> newNodes) |
org.apache.flink.runtime.blocklist.BlockedNodeAdditionResult |
DefaultBlocklistTracker.addNewBlockedNodes(Collection<BlockedNode> newNodes) |
void |
BlocklistHandler.addNewBlockedNodes(Collection<BlockedNode> newNodes)
Add new blocked node records.
|
org.apache.flink.runtime.blocklist.BlockedNodeAdditionResult |
BlocklistTracker.addNewBlockedNodes(Collection<BlockedNode> newNodes)
Add new blocked node records.
|
void |
DefaultBlocklistHandler.addNewBlockedNodes(Collection<BlockedNode> newNodes) |
void |
BlocklistOperations.addNewBlockedNodes(Collection<BlockedNode> newNodes)
Add new blocked node records.
|
void |
BlocklistContext.blockResources(Collection<BlockedNode> blockedNodes)
Block resources on the nodes.
|
CompletableFuture<Acknowledge> |
BlocklistListener.notifyNewBlockedNodes(Collection<BlockedNode> newNodes)
Notify new blocked node records.
|
void |
BlocklistContext.unblockResources(Collection<BlockedNode> unblockedNodes)
Unblock resources on the nodes.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
JobMaster.notifyNewBlockedNodes(Collection<BlockedNode> newNodes) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
ResourceManager.notifyNewBlockedNodes(Collection<BlockedNode> newNodes) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.