hadoop - Apache Flink：无法解析 Yarn 中的 JobManager

Question

使用 Eclipse IDE 将 Flink 提交到 Yarn 单节点集群我得到：org.apache.flink.client.program.ProgramInvocationException: Failed to resolve JobManager

Jar 将文件从 Hdfs 中的一个位置复制到另一个位置，并在集群上本地执行的工作文件，例如 sudo bin/flink run -c Test ./examples/MyJar.jar hdfs://localhost:9000/flink/in.txt hdfs ://localhost:9000/flink/out.txt

代码：

ExecutionEnvironment envRemote =  
ExecutionEnvironment.createRemoteEnvironment
(FLINK_SERVER_URL,FLINK PORT,PATH_JAR_ON_CLIENT);

DataSet<String> data = 
envRemote.readTextFile("hdfs://localhost:9000/flink/in.txt");

data.writeAsText("hdfs://localhost:9000/flink/out.txt");
envRemote.execute();