Package | Description |
---|---|
org.apache.flink.runtime.resourcemanager |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
ResourceManager.heartbeatFromTaskManager(ResourceID resourceID,
TaskExecutorHeartbeatPayload heartbeatPayload) |
CompletableFuture<Void> |
ResourceManagerGateway.heartbeatFromTaskManager(ResourceID heartbeatOrigin,
TaskExecutorHeartbeatPayload heartbeatPayload)
Sends the heartbeat to resource manager from task manager.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.