@ Override public void informAboutEvaluatorFailures ( final Set < String > evaluatorIds ) { for ( String evaluatorId : evaluatorIds ) { LOG . log ( Level . WARNING , "Container [" + evaluatorId + "] has failed during driver restart process, FailedEvaluatorHandler will be triggered, but " + "no additional evaluator can be requested due to YARN-2433." ) ; // trigger a failed evaluator event this . reefEventHandlers . onResourceStatus ( ResourceStatusEventImpl . newBuilder ( ) . setIdentifier ( evaluatorId ) . setState ( State . FAILED ) . setExitCode ( 1 ) . setDiagnostics ( "Container [" + evaluatorId + "] failed during driver restart process." ) . build ( ) ) ; } }
Calls the appropriate handler via REEFEventHandlers which is a runtime specific implementation of the YARN runtime .