不成功的报错是啥？ Best, tison.
nicygan <[email protected]> 于2020年3月7日周六 上午11:14写道： > dear all： > > 我用的flink版本1.9，现在我把flinksql语句生成了jobGroph，现在我不知道如何提交到yarn上，以pre-job方式运行。我尝试通过生成 > yarnClusterDescriptor提交代码，但不成功，代码大致如下，各位有没有成功示例求分享。 > > ...... > JobGraph jobGraph = env.getStreamGraph("StreamSql").getJobGraph(); > ...... > ...... > yarnClusterDescriptor.deployJobCluster( > clusterSpecification, > jobGraph, true); > >
