private void failSessionDuringDeployment ( YarnClient yarnClient , YarnClientApplication yarnApplication ) { LOG . info ( "Killing YARN application" ) ; try { yarnClient . killApplication ( yarnApplication . getNewApplicationResponse ( ) . getApplicationId ( ) ) ; } catch ( Exception e ) { // we only log a debug message here because the "killApplication" call is a best-effort // call (we don't know if the application has been deployed when the error occured). LOG . debug ( "Error while killing YARN application" , e ) ; } yarnClient . stop ( ) ; }
Kills YARN application and stops YARN client .