@Override public boolean onKill(Scheduler.KillTopologyRequest request){
  String topologyName=LocalContext.topologyName(config);
  LOG.info("Command to kill topology: " + topologyName);
  isTopologyKilled=true;
synchronized (processToContainer) {
    for (    Process p : processToContainer.keySet()) {
      int index=processToContainer.get(p);
      LOG.info("Killing executor for container: " + index);
      p.destroy();
      LOG.info("Killed executor for container: " + index);
    }
    processToContainer.clear();
  }
  return true;
}

@ Override public boolean onKill ( Scheduler . KillTopologyRequest request ) { String topologyName = LocalContext . topologyName ( config ) ; LOG . info ( "Command to kill topology: " + topologyName ) ; isTopologyKilled = true ; synchronized ( processToContainer ) { for ( Process p : processToContainer . keySet ( ) ) { int index = processToContainer . get ( p ) ; LOG . info ( "Killing executor for container: " + index ) ; p . destroy ( ) ; LOG . info ( "Killed executor for container: " + index ) ; } processToContainer . clear ( ) ; } return true ; }
handler to kill topology
