@ Override public synchronized void stop ( ) { if ( this . stopStatus . isStopInProgress ( ) ) { return ; } this . stopStatus . setStopInprogress ( true ) ; LOGGER . info ( "Stopping the Gobblin Cluster Manager" ) ; if ( this . idleProcessThread != null ) { try { this . idleProcessThread . join ( ) ; } catch ( InterruptedException ie ) { Thread . currentThread ( ) . interrupt ( ) ; } } // Send a shutdown request to all GobblinTaskRunners unless running in standalone mode. // In standalone mode a failing manager should not stop the whole cluster. if ( ! this . isStandaloneMode ) { sendShutdownRequest ( ) ; } stopAppLauncherAndServices ( ) ; this . multiManager . disconnect ( ) ; }
Stop the Gobblin Cluster Manager .