flink jobgraph提交

cetgtptt  于 2021-06-24  发布在  Flink
关注(0)|答案(0)|浏览(289)

我正试图将给定的sql编译成flink的作业图,并希望提交给yarn。

JobGraph jobGraph = streamExecutionEnv.getStreamGraph().getJobGraph();

YarnDeployer().deployJob(jobGraph);
``` `YarnDeployer` 是使用 `YarnClusterDescriptor` 以及 `ClusterSpecification` flink的api提交作业。
在emr中,我启动了flink-warn会话,并使用flink-run提交了作业。
我得到以下错误:程序没有包含flink作业。也许你忘了打电话 `execute()` 关于执行环境。
是否可以在不执行的情况下运行jobgraph?我不想连续工作。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题