jobGroph如何以pre-job的方式提交到yarn运行

[nicygan]

dear all：
    
我用的flink版本1.9，现在我把flinksql语句生成了jobGroph，现在我不知道如何提交到yarn上，以pre-job方式运行。我尝试通过生成
yarnClusterDescriptor提交代码，但不成功，代码大致如下，各位有没有成功示例求分享。

......
JobGraph jobGraph = env.getStreamGraph("StreamSql").getJobGraph();
......
......
yarnClusterDescriptor.deployJobCluster(
clusterSpecification,
      jobGraph, true);