org.apache.flink.runtime.scheduler.adaptive

Interface LabeledGlobalFailureHandler

public interface LabeledGlobalFailureHandler

An interface for handling and associating global failures with labels from FailureEnricher. In context of a scheduler we distinguish between local and global failures. Global failure is the one that happens in context of the scheduler (in the JobManager process) and local failure is one that is "local" to an executing task.

Method Summary

Modifier and Type	Method and Description
void	handleGlobalFailure(Throwable cause, CompletableFuture<Map<String,String>> failureLabels) An adapted version of GlobalFailureHandler that handles and associates global failures with enricher labels.

Method Detail

handleGlobalFailure

void handleGlobalFailure(Throwable cause,
                         CompletableFuture<Map<String,String>> failureLabels)

An adapted version of GlobalFailureHandler that handles and associates global failures with enricher labels.

Parameters:

cause - A cause that describes the global failure.

failureLabels - Labels providing an additional context about the failure.