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 `[]`
---