|
Change Return Type Future<Object> to CompletableFuture<Object> in method public retrievePayload() : CompletableFuture<Object> in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest.TestingHeartbeatListener |
From |
To |
|
Change Return Type Future<Void> to CompletableFuture<Void> in method public retrievePayload() : CompletableFuture<Void> in class org.apache.flink.runtime.jobmaster.JobMaster.TaskManagerHeartbeatListener |
From |
To |
|
Change Return Type Future<Void> to CompletableFuture<Void> in method public retrievePayload() : CompletableFuture<Void> in class org.apache.flink.runtime.resourcemanager.ResourceManager.JobManagerHeartbeatListener |
From |
To |
|
Change Return Type Future<Void> to CompletableFuture<Void> in method public retrievePayload() : CompletableFuture<Void> in class org.apache.flink.runtime.resourcemanager.ResourceManager.TaskManagerHeartbeatListener |
From |
To |
|
Change Return Type Future<O> to CompletableFuture<O> in method public retrievePayload() : CompletableFuture<O> in class org.apache.flink.runtime.heartbeat.HeartbeatListener |
From |
To |
|
Change Return Type Future<Void> to CompletableFuture<Void> in method public retrievePayload() : CompletableFuture<Void> in class org.apache.flink.runtime.jobmaster.JobMaster.ResourceManagerHeartbeatListener |
From |
To |
|
Change Return Type Future<Void> to CompletableFuture<Void> in method public retrievePayload() : CompletableFuture<Void> in class org.apache.flink.runtime.taskexecutor.TaskExecutor.JobManagerHeartbeatListener |
From |
To |
|
Change Return Type Future<ResourceID> to CompletableFuture<ResourceID> in method package getTimeoutFuture() : CompletableFuture<ResourceID> in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest.TestingHeartbeatListener |
From |
To |
|
Change Return Type Future<SlotReport> to CompletableFuture<SlotReport> in method public retrievePayload() : CompletableFuture<SlotReport> in class org.apache.flink.runtime.taskexecutor.TaskExecutor.ResourceManagerHeartbeatListener |
From |
To |
|
Change Variable Type futurePayload : Future<O> to futurePayload : CompletableFuture<O> in method public requestHeartbeat(requestOrigin ResourceID, heartbeatPayload I) : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerImpl |
From |
To |
|
Change Variable Type futurePayload : Future<O> to futurePayload : CompletableFuture<O> in method public run() : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerSenderImpl |
From |
To |
|
Change Variable Type timeout : Future<ResourceID> to timeout : CompletableFuture<ResourceID> in method public testTargetUnmonitoring() : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest |
From |
To |
|
Change Variable Type futureTimeout : Future<ResourceID> to futureTimeout : CompletableFuture<ResourceID> in method public testHeartbeatCluster() : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest |
From |
To |
|
Change Variable Type timeoutFuture : Future<ResourceID> to timeoutFuture : CompletableFuture<ResourceID> in method public testHeartbeatTimeout() : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest |
From |
To |