code: private void execute() throws Exception {
  		if (result == null) {
  			env.execute(executionName);
  		} else {
  			output.write(executionName.toString(), System.out, result);
  		}
  
  		System.out.println();
  		algorithm.printAnalytics(System.out);
  
  		if (jobDetailsPath.getValue() != null) {
  			writeJobDetails(env, jobDetailsPath.getValue());
  		}
  	}
docs: Execute the Flink job.
  
  @throws Exception on error