[hotfix] Avoid redundant slot release operations

InfinitiesLoop · Feb 24, 2018 · 4fc3bcf · 4fc3bcf
1 parent 107c8e0
commit 4fc3bcf
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManager.java b/...runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManager.java
@@ -537,9 +537,8 @@ public boolean release(Throwable cause) {
  if (parent != null) {
  // we remove ourselves from our parent if we no longer have children
  parent.releaseChild(getGroupId());
- } else {
+ } else if (allTaskSlots.remove(getSlotRequestId()) != null) {
  // we are the root node --> remove the root node from the list of task slots
- allTaskSlots.remove(getSlotRequestId());
 
  if (!slotContextFuture.isDone() || slotContextFuture.isCompletedExceptionally()) {
  synchronized (lock) {