code: @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();
    }
docs: ProcessMonitor callback function
  Restarts SQL Compiler processes