You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/03/23 11:38:34 UTC
[5/9] flink git commit: [hotfix] Remove unused method from SlotPool
[hotfix] Remove unused method from SlotPool
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2e40f380
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2e40f380
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2e40f380
Branch: refs/heads/master
Commit: 2e40f3807b2bc0c2349b967f2fb9d3d10eddcdca
Parents: 6c70b7b
Author: Till Rohrmann <tr...@apache.org>
Authored: Wed Mar 21 18:44:25 2018 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Fri Mar 23 12:32:38 2018 +0100
----------------------------------------------------------------------
.../apache/flink/runtime/jobmaster/slotpool/SlotPool.java | 10 ----------
1 file changed, 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/2e40f380/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java
index 6040b41..662e71a 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java
@@ -69,7 +69,6 @@ import java.util.Set;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionException;
import java.util.concurrent.TimeUnit;
-import java.util.concurrent.TimeoutException;
import java.util.stream.Collectors;
import java.util.stream.Stream;
@@ -724,15 +723,6 @@ public class SlotPool extends RpcEndpoint implements SlotPoolGateway, AllocatedS
}
}
- private void checkTimeoutSlotAllocation(SlotRequestId slotRequestID) {
- PendingRequest request = pendingRequests.removeKeyA(slotRequestID);
- if (request != null) {
- failPendingRequest(
- request,
- new TimeoutException("Slot allocation request " + slotRequestID + " timed out"));
- }
- }
-
private void stashRequestWaitingForResourceManager(final PendingRequest pendingRequest) {
log.info("Cannot serve slot request, no ResourceManager connected. " +