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