akalash commented on a change in pull request #16637:
URL: https://github.com/apache/flink/pull/16637#discussion_r686849015
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureManager.java
##########
@@ -136,6 +135,8 @@ public void checkFailureCounter(CheckpointException
exception, long checkpointId
// ignore
break;
+ case EXCEPTION:
Review comment:
Ok, then. We can migrate from EXCEPTION enum to IO_EXCEPTION but we can
keep the original message from EXCEPTION and we can add the second sentence
with an explanation about IO-exception.
So right now we have the message `An Exception occurred while triggering the
checkpoint.` and we can transform it to something like `An Exception occurred
while triggering the checkpoint. IO-problem detected.`
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
