org.apache.flink.runtime.shuffle

Interface ShuffleMasterContext

All Known Implementing Classes:

ShuffleMasterContextImpl

public interface ShuffleMasterContext

Shuffle context used to create ShuffleMaster. It can work as a proxy to other cluster components and hide these components from users. For example, the customized shuffle master can access the cluster fatal error handler through this context and in the future, more components like the resource manager partition tracker will be accessible.

Method Summary

Modifier and Type	Method and Description
Configuration	getConfiguration()
void	onFatalError(Throwable throwable) Handles the fatal error if any.

Method Detail

getConfiguration

Configuration getConfiguration()

Returns:

the cluster configuration.

onFatalError

void onFatalError(Throwable throwable)

Handles the fatal error if any.