code: @Override
  	public void onFatalError(Throwable exception) {
  		LOG.error("Fatal error occurred while executing the TaskManager. Shutting it down...", exception);
  
  		if (ExceptionUtils.isJvmFatalOrOutOfMemoryError(exception)) {
  			terminateJVM();
  		} else {
  			closeAsync();
  
  			FutureUtils.orTimeout(terminationFuture, FATAL_ERROR_SHUTDOWN_TIMEOUT_MS, TimeUnit.MILLISECONDS);
  
  			terminationFuture.whenComplete(
  				(Void ignored, Throwable throwable) -> {
  					terminateJVM();
  				});
  		}
  	}
docs: --------------------------------------------------------------------------------------------