Github user GJL commented on a diff in the pull request:

    https://github.com/apache/flink/pull/6386#discussion_r204394265
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManager.java
 ---
    @@ -384,6 +393,8 @@ private MultiTaskSlot(
                MultiTaskSlot allocateMultiTaskSlot(SlotRequestId 
slotRequestId, AbstractID groupId) {
                        Preconditions.checkState(!super.contains(groupId));
     
    +                   LOG.debug("Create nested multi task slot [{}] in parent 
multi task slot [{}] for group {}.", slotRequestId, getSlotRequestId(), 
groupId);
    --- End diff --
    
    add `[]`


---

Reply via email to