[FLINK-17758][runtime] Remove unused AdaptedRestartPipelinedRegionStr…

…ategyNG
spotify · May 18, 2020 · fd051c9 · fd051c9
1 parent a17da14
commit fd051c9
Show file tree

Hide file tree

Showing 8 changed files with 4 additions and 1,271 deletions.
diff --git a/...apache/flink/runtime/executiongraph/failover/AdaptedRestartPipelinedRegionStrategyNG.java b/...apache/flink/runtime/executiongraph/failover/AdaptedRestartPipelinedRegionStrategyNG.java
diff --git a/...rc/main/java/org/apache/flink/runtime/executiongraph/failover/FailoverStrategyLoader.java b/...rc/main/java/org/apache/flink/runtime/executiongraph/failover/FailoverStrategyLoader.java
@@ -38,9 +38,6 @@ public class FailoverStrategyLoader {
  /** Config name for the {@link RestartIndividualStrategy}. */
  public static final String INDIVIDUAL_RESTART_STRATEGY_NAME = "individual";
 
- /** Config name for the {@link AdaptedRestartPipelinedRegionStrategyNG}. */
- public static final String PIPELINED_REGION_RESTART_STRATEGY_NAME = "region";
-
  // ------------------------------------------------------------------------
 
  /**
@@ -62,9 +59,6 @@ public static FailoverStrategy.Factory loadFailoverStrategy(Configuration config
  case FULL_RESTART_STRATEGY_NAME:
  return new RestartAllStrategy.Factory();
 
- case PIPELINED_REGION_RESTART_STRATEGY_NAME:
- return new AdaptedRestartPipelinedRegionStrategyNG.Factory();
-
  case INDIVIDUAL_RESTART_STRATEGY_NAME:
  return new RestartIndividualStrategy.Factory();
 

diff --git a/...t/java/org/apache/flink/runtime/checkpoint/FailoverStrategyCheckpointCoordinatorTest.java b/...t/java/org/apache/flink/runtime/checkpoint/FailoverStrategyCheckpointCoordinatorTest.java
@@ -25,7 +25,6 @@
 import org.apache.flink.runtime.executiongraph.Execution;
 import org.apache.flink.runtime.executiongraph.ExecutionAttemptID;
 import org.apache.flink.runtime.executiongraph.ExecutionVertex;
-import org.apache.flink.runtime.executiongraph.failover.AdaptedRestartPipelinedRegionStrategyNG;
 import org.apache.flink.runtime.executiongraph.failover.FailoverStrategy;
 import org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration;
 import org.apache.flink.runtime.state.SharedStateRegistry;
@@ -57,8 +56,7 @@ public void setUp() {
 
  /**
  * Tests that {@link CheckpointCoordinator#abortPendingCheckpoints(CheckpointException)}
- * called by {@link AdaptedRestartPipelinedRegionStrategyNG} could handle
- * the {@code currentPeriodicTrigger} null situation well.
+ * called on job failover could handle the {@code currentPeriodicTrigger} null case well.
  */
  @Test
  public void testAbortPendingCheckpointsWithTriggerValidation() {