[FLINK-30100][checkpointing] Remove the unused CheckpointFailureReason

mbalassi · Nov 25, 2022 · aa0cd87 · aa0cd87
1 parent cf78eb1
commit aa0cd87
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 15 deletions.
diff --git a/...k-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureManager.java b/...k-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureManager.java
@@ -222,20 +222,16 @@ public void checkFailureCounter(CheckpointException exception, long checkpointId
  CheckpointFailureReason reason = exception.getCheckpointFailureReason();
  switch (reason) {
  case PERIODIC_SCHEDULER_SHUTDOWN:
- case TOO_MANY_CONCURRENT_CHECKPOINTS:
  case TOO_MANY_CHECKPOINT_REQUESTS:
  case MINIMUM_TIME_BETWEEN_CHECKPOINTS:
  case NOT_ALL_REQUIRED_TASKS_RUNNING:
  case CHECKPOINT_SUBSUMED:
  case CHECKPOINT_COORDINATOR_SUSPEND:
  case CHECKPOINT_COORDINATOR_SHUTDOWN:
- case JOB_FAILURE:
  case JOB_FAILOVER_REGION:
  // for compatibility purposes with user job behavior
  case CHECKPOINT_DECLINED_TASK_NOT_READY:
  case CHECKPOINT_DECLINED_TASK_CLOSING:
- case CHECKPOINT_DECLINED_TASK_NOT_CHECKPOINTING:
- case CHECKPOINT_DECLINED_ALIGNMENT_LIMIT_EXCEEDED:
  case CHECKPOINT_DECLINED_ON_CANCELLATION_BARRIER:
  case CHECKPOINT_DECLINED_SUBSUMED:
  case CHECKPOINT_DECLINED_INPUT_END_OF_STREAM:

diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureReason.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureReason.java
@@ -22,9 +22,6 @@
 public enum CheckpointFailureReason {
  PERIODIC_SCHEDULER_SHUTDOWN(true, "Periodic checkpoint scheduler is shut down."),
 
- TOO_MANY_CONCURRENT_CHECKPOINTS(
- true, "The maximum number of concurrent checkpoints is exceeded"),
-
  TOO_MANY_CHECKPOINT_REQUESTS(true, "The maximum number of queued checkpoint requests exceeded"),
 
  MINIMUM_TIME_BETWEEN_CHECKPOINTS(
@@ -49,27 +46,19 @@ public enum CheckpointFailureReason {
 
  CHECKPOINT_DECLINED_TASK_CLOSING(false, "Checkpoint was declined (task is closing)"),
 
- CHECKPOINT_DECLINED_TASK_NOT_CHECKPOINTING(false, "Task does not support checkpointing"),
-
  CHECKPOINT_DECLINED_SUBSUMED(
  false, "Checkpoint was canceled because a barrier from newer checkpoint was received."),
 
  CHECKPOINT_DECLINED_ON_CANCELLATION_BARRIER(
  false, "Task received cancellation from one of its inputs"),
 
- CHECKPOINT_DECLINED_ALIGNMENT_LIMIT_EXCEEDED(
- false,
- "The checkpoint alignment phase needed to buffer more than the configured maximum bytes"),
-
  CHECKPOINT_DECLINED_INPUT_END_OF_STREAM(
  false, "Checkpoint was declined because one input stream is finished"),
 
  CHECKPOINT_COORDINATOR_SHUTDOWN(false, "CheckpointCoordinator shutdown."),
 
  CHECKPOINT_COORDINATOR_SUSPEND(false, "Checkpoint Coordinator is suspending."),
 
- JOB_FAILURE(false, "The job has failed."),
-
  JOB_FAILOVER_REGION(false, "FailoverRegion is restarting."),
 
  TASK_FAILURE(false, "Task has failed."),