@ Override public void notifyFailure ( Set < String > errorProcessNames ) { if ( errorProcessNames != null ) { LOG . warn ( "Missing pings from : " + errorProcessNames . toString ( ) ) ; } else { LOG . warn ( "No heartbeats registered" ) ; } healthInspector . stopAndWait ( ) ; healthInspector = new HealthInspector ( this ) ; inputFlowletService . restartService ( healthInspector ) ; healthInspector . startAndWait ( ) ; }
ProcessMonitor callback function Restarts SQL Compiler processes