public void resetRunningTasks ( TaskType type ) { Map < String , Integer > runningMap = ( type == TaskType . MAP ? poolRunningMaps : poolRunningReduces ) ; for ( String poolName : runningMap . keySet ( ) ) { runningMap . put ( poolName , 0 ) ; } }
Set the number of running tasks in all pools to zero