private synchronized void onEvaluatorKilled ( final EvaluatorStatusPOJO message ) { assert message . getState ( ) == State . KILLED ; assert this . stateManager . isClosing ( ) ; LOG . log ( Level . WARNING , "Evaluator {0} killed completely." , getId ( ) ) ; this . stateManager . setKilled ( ) ; }
Process an evaluator message that indicates that the evaluator completed the unclean shut down request .