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 |