private int killSession ( String sessionId ) throws IOException { try { System . out . printf ( "Killing %s" , sessionId ) ; ClusterManagerService . Client client = getCMSClient ( ) ; try { client . killSession ( sessionId ) ; } catch ( SafeModeException e ) { throw new IOException ( "Cannot kill session yet, ClusterManager is in Safe Mode" ) ; } System . err . printf ( "%s killed" , sessionId ) ; } catch ( TException e ) { throw new IOException ( e ) ; } return 0 ; }
Tells the cluster manager to kill the session with a given id