GJL commented on a change in pull request #11857:
URL: https://github.com/apache/flink/pull/11857#discussion_r412745971
##########
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/failover/flip1/RestartPipelinedRegionFailoverStrategyBuildingTest.java
##########
@@ -55,9 +56,9 @@ public void testIndividualVertices() {
RestartPipelinedRegionFailoverStrategy strategy = new
RestartPipelinedRegionFailoverStrategy(topology);
- FailoverRegion r1 = strategy.getFailoverRegion(v1.getId());
- FailoverRegion r2 = strategy.getFailoverRegion(v2.getId());
- FailoverRegion r3 = strategy.getFailoverRegion(v3.getId());
+ SchedulingPipelinedRegion r1 =
strategy.getFailoverRegion(v1.getId());
Review comment:
Tests in this file should be migrated to something like
`PipelinedRegionComputeUtilTest`
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
