@ 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 , null ) ; // for each container, run its own executor for ( PackingPlan . ContainerPlan container : packing . getContainers ( ) ) { startExecutor ( container . getId ( ) , container . getInstances ( ) ) ; } } LOG . info ( "Executor for each container have been started." ) ; return true ; }
Schedule the provided packed plan