OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
verticesToRestart1 = new HashSet<>(Arrays.asList(new ExecutionVertexID(jobVertexID,0),new ExecutionVertexID(jobVertexID,4)))verticesToRestart1 = Arrays.asList(new ExecutionVertexID(jobVertexID,4),new ExecutionVertexID(jobVertexID,0))new HashSet<>(Arrays.asList(new ExecutionVertexID(jobVertexID,0),new ExecutionVertexID(jobVertexID,4)))Arrays.asList(new ExecutionVertexID(jobVertexID,4),new ExecutionVertexID(jobVertexID,0))flink33d81ccb69ac82ef030c54cb12235dec540554ddorg.apache.flink.runtime.scheduler.strategy.EagerSchedulingStrategyTest
_195
_299
_1verticesToRestart1
_2verticesToRestart1
v0new ExecutionVertexID(jobVertexID,0)
v1new ExecutionVertexID(jobVertexID,4)
  • java.util.Arrays
  • java.util.HashSet
v0new ExecutionVertexID(jobVertexID,0)
v1new ExecutionVertexID(jobVertexID,4)
AssignedToTrue