我正试图将给定的sql编译成flink的作业图,并希望提交给yarn。
JobGraph jobGraph = streamExecutionEnv.getStreamGraph().getJobGraph();
YarnDeployer().deployJob(jobGraph);
``` `YarnDeployer` 是使用 `YarnClusterDescriptor` 以及 `ClusterSpecification` flink的api提交作业。
在emr中,我启动了flink-warn会话,并使用flink-run提交了作业。
我得到以下错误:程序没有包含flink作业。也许你忘了打电话 `execute()` 关于执行环境。
是否可以在不执行的情况下运行jobgraph?我不想连续工作。
暂无答案!
目前还没有任何答案,快来回答吧!