org.apache.flink.streaming.runtime.tasks

Interface CheckpointExceptionHandler

public interface CheckpointExceptionHandler

Handler for exceptions that happen on checkpointing. The handler can reject and rethrow the offered exceptions.

Method Summary

Modifier and Type	Method and Description
void	tryHandleCheckpointException(org.apache.flink.runtime.checkpoint.CheckpointMetaData checkpointMetaData, Exception exception) Offers the exception for handling.

Method Detail

tryHandleCheckpointException

void tryHandleCheckpointException(org.apache.flink.runtime.checkpoint.CheckpointMetaData checkpointMetaData,
                                  Exception exception)
                           throws Exception

Offers the exception for handling. If the exception cannot be handled from this instance, it is rethrown.

Parameters:

checkpointMetaData - metadata for the checkpoint for which the exception occurred.

exception - the exception to handle.

Throws:

Exception - rethrows the exception if it cannot be handled.