OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
return !started && taskSlots.stream().allMatch(slot -> slot.getMemoryManager().isShutdown());return !started && taskSlots.values().stream().allMatch(slot -> slot.getMemoryManager().isShutdown());taskSlotstaskSlots.values()flink516aee357f9653d2d7b71411f237a304033ff70borg.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
_168
_282
_1taskSlots
_2taskSlots
TCIVartaskSlots
TCIVartaskSlots
UsesTrue
taskSlots.forEach(TaskSlot::close);taskSlots.values().forEach(TaskSlot::close);taskSlotstaskSlots.values()flink516aee357f9653d2d7b71411f237a304033ff70borg.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
_168
_282
_1taskSlots
_2taskSlots
TCIVartaskSlots
TCIVartaskSlots
UsesTrue