public synchronized void stopExecution(){
  if (stopped.get()) {
    return;
  }
  stopped.set(true);
  subscribers.close();
  stopTimer.cancel();
  stopTimer.purge();
  try {
    TestBaseUtils.stopCluster(cluster,new FiniteDuration(1000,TimeUnit.SECONDS));
  }
 catch (  Exception e) {
    e.printStackTrace();
  }
}

public synchronized void stopExecution ( ) { if ( stopped . get ( ) ) { return ; } stopped . set ( true ) ; subscribers . close ( ) ; stopTimer . cancel ( ) ; stopTimer . purge ( ) ; try { TestBaseUtils . stopCluster ( cluster , new FiniteDuration ( 1000 , TimeUnit . SECONDS ) ) ; } catch ( Exception e ) { e . printStackTrace ( ) ; } }
stop the execution of the test . < p > shutting the local cluster down will , will notify the sockets when the sinks are closed . thus terminating the execution gracefully .
