@Override
    public JobExecutionResult execute(String jobName) throws Exception {
        // transform the streaming program into a JobGraph
        StreamGraph streamGraph = getStreamGraph();
        streamGraph.setJobName(jobName);
        return execute(streamGraph);
    }
Executes the JobGraph of the on a mini cluster of CLusterUtil with a user
specified name.

@param jobName
           name of the job
@return The result of the job execution, containing elapsed time and accumulators.
core/src/main/java/com/dtstack/flink/sql/environment/MyLocalStreamEnvironment.java