Apache Flink：在预定义上下文中运行时无法实例化 RemoteEnvironment

Question

有谁知道，运行远程Flink集群上的程序出现以下错误的根源是什么？

我该如何解决？

 org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.
    at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:512)
    at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:395)
    at org.apache.flink.client.program.Client.runBlocking(Client.java:252)
    at org.apache.flink.client.CliFrontend.executeProgramBlocking(CliFrontend.java:675)
    at org.apache.flink.client.CliFrontend.run(CliFrontend.java:326)
    at org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:977)
    at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1027)
Caused by: org.apache.flink.api.common.InvalidProgramException: The RemoteEnvironment cannot be instantiated when running in a pre-defined context (such as Command Line Client, Scala Shell, or TestEnvironment)
    at org.apache.flink.api.java.RemoteEnvironment.<init>(RemoteEnvironment.java:118)
    at org.apache.flink.api.java.RemoteEnvironment.<init>(RemoteEnvironment.java:78)
    at org.apache.flink.api.java.ExecutionEnvironment.createRemoteEnvironment(ExecutionEnvironment.java:1155)
    at org.apache.flink.test.myProj.main(myProj.java:133)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:606)
    at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:497)
    ... 6 more

Answer 1

在你的Flink程序中，你需要使用

ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

检索 ExecutionEnvironment。这会自动获取本地环境（当您从 IDE 执行时）或集群环境（当您使用命令行客户端时）。

如果您想将 Flink 程序提交到远程集群，则只能使用 RemoteEnvironment。

Answer 2

要将您的作业提交到远程环境（您的代码使用 .createRemoteEnvironment），您只能通过 API 调用而不是从 CLI

Apache Flink：在预定义上下文中运行时无法实例化 RemoteEnvironment

Apache Flink: The RemoteEnvironment cannot be instantiated when running in a pre-defined context

apache-flink

Apache Flink：在预定义上下文中 运行 时无法实例化 RemoteEnvironment

Apache Flink: The RemoteEnvironment cannot be instantiated when running in a pre-defined context

apache-flink

Apache Flink：在预定义上下文中运行时无法实例化 RemoteEnvironment