OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
verticesToRestart2 = new HashSet<>(Arrays.asList(new ExecutionVertexID(jobVertexID,1),new ExecutionVertexID(jobVertexID,2),new ExecutionVertexID(jobVertexID,3)))verticesToRestart2 = Arrays.asList(new ExecutionVertexID(jobVertexID,2),new ExecutionVertexID(jobVertexID,1),new ExecutionVertexID(jobVertexID,3))new HashSet<>(Arrays.asList(new ExecutionVertexID(jobVertexID,1),new ExecutionVertexID(jobVertexID,2),new ExecutionVertexID(jobVertexID,3)))Arrays.asList(new ExecutionVertexID(jobVertexID,2),new ExecutionVertexID(jobVertexID,1),new ExecutionVertexID(jobVertexID,3))flink33d81ccb69ac82ef030c54cb12235dec540554ddorg.apache.flink.runtime.scheduler.strategy.EagerSchedulingStrategyTest
_1100
_2104
_1verticesToRestart2
_2verticesToRestart2
v0new ExecutionVertexID(jobVertexID,3)
v1new ExecutionVertexID(jobVertexID,1)
v2new ExecutionVertexID(jobVertexID,2)
  • java.util.Arrays
  • java.util.HashSet
v0new ExecutionVertexID(jobVertexID,3)
v1new ExecutionVertexID(jobVertexID,1)
v2new ExecutionVertexID(jobVertexID,2)
AssignedToTrue