code: @Override
  	public JobExecutionResult execute(String jobName) throws Exception {
  		PlanExecutor executor = getExecutor();
  
  		Plan p = createProgramPlan(jobName);
  
  		// Session management is disabled, revert this commit to enable
  		//p.setJobId(jobID);
  		//p.setSessionTimeout(sessionTimeout);
  
  		JobExecutionResult result = executor.executePlan(p);
  
  		this.lastJobExecutionResult = result;
  		return result;
  	}
docs: ------------------------------------------------------------------------