| 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 |