code: public JobExecutionResult execute(String job_name) throws Exception {
  		distributeFiles();
  		JobExecutionResult result = this.env.execute(job_name);
  		return result;
  	}
docs: A thin wrapper layer over {@link StreamExecutionEnvironment#execute(java.lang.String)}.
  
  @return The result of the job execution, containing elapsed time and accumulators.
  @throws Exception which occurs during job execution.