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)) | flink | 33d81ccb69ac82ef030c54cb12235dec540554dd | org.apache.flink.runtime.scheduler.strategy.EagerSchedulingStrategyTest | | _1 | verticesToRestart2 |
---|
_2 | verticesToRestart2 |
---|
| v0 | new ExecutionVertexID(jobVertexID,3) |
---|
v1 | new ExecutionVertexID(jobVertexID,1) |
---|
v2 | new ExecutionVertexID(jobVertexID,2) |
---|
| - java.util.Arrays
- java.util.HashSet
| v0 | new ExecutionVertexID(jobVertexID,3) |
---|
v1 | new ExecutionVertexID(jobVertexID,1) |
---|
v2 | new ExecutionVertexID(jobVertexID,2) |
---|
| AssignedTo | True |