public Boolean isStageFinished(String jobID, Global.STAGE stage) {
		int processedTask = getCommittedTask(jobID, stage).size();
		if (stage == Global.STAGE.MAP )
			logger.debug("Done " + processedTask + " maps, waiting for " + numSplits);
		else
			logger.debug("Done " + processedTask + " reduces, waiting for " + numReduceQ);
		
		if ( stage == Global.STAGE.MAP  && processedTask > numSplits )
			logger.warn("Processed more maps than available");
		else if ( stage == Global.STAGE.REDUCE && processedTask > numReduceQ )
			logger.warn("Processed more reduces than available");

		if ( stage == Global.STAGE.MAP  )
			return processedTask >= numSplits;
		else
			return processedTask >= numReduceQ;
	}