@Override public boolean onSchedule(PackingPlan packing){
  LOG.info("Starting to deploy topology: " + LocalContext.topologyName(config));
synchronized (processToContainer) {
    LOG.info("Starting executor for TMaster");
    startExecutor(0);
    for (    PackingPlan.ContainerPlan container : packing.getContainers()) {
      startExecutor(container.getId());
    }
  }
  LOG.info("Executor for each container have been started.");
  return true;
}

@ Override public boolean onSchedule ( PackingPlan packing ) { LOG . info ( "Starting to deploy topology: " + LocalContext . topologyName ( config ) ) ; synchronized ( processToContainer ) { LOG . info ( "Starting executor for TMaster" ) ; startExecutor ( 0 ) ; for ( PackingPlan . ContainerPlan container : packing . getContainers ( ) ) { startExecutor ( container . getId ( ) ) ; } } LOG . info ( "Executor for each container have been started." ) ; return true ; }
schedule the provided packed plan
