You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2022/11/25 13:12:27 UTC
[flink] 04/04: [FLINK-30100][checkpointing] Remove the unused CheckpointFailureReason
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit aa0cd873709e6b5d4fc45ee67aa36d131b90d8e9
Author: 1996fanrui <19...@gmail.com>
AuthorDate: Sun Nov 20 21:45:04 2022 +0800
[FLINK-30100][checkpointing] Remove the unused CheckpointFailureReason
---
.../flink/runtime/checkpoint/CheckpointFailureManager.java | 4 ----
.../flink/runtime/checkpoint/CheckpointFailureReason.java | 11 -----------
2 files changed, 15 deletions(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureManager.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureManager.java
index 61404496529..4b33a0aab1c 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureManager.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureManager.java
@@ -222,20 +222,16 @@ public class CheckpointFailureManager {
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
index 75a70c01212..e85b0130422 100644
--- 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 @@ package org.apache.flink.runtime.checkpoint;
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,18 +46,12 @@ 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"),
@@ -68,8 +59,6 @@ public enum CheckpointFailureReason {
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."),