return !started && taskSlots.stream().allMatch(slot -> slot.getMemoryManager().isShutdown()); | return !started && taskSlots.values().stream().allMatch(slot -> slot.getMemoryManager().isShutdown()); | taskSlots | taskSlots.values() | flink | 516aee357f9653d2d7b71411f237a304033ff70b | org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable | | | | | | Uses | True |