The program finished with the following exception:
java.lang.IllegalStateException: No Executor found. Please make sure to export the HADOOP_CLASSPATH environment variable or have hadoop in your classpath. For more information refer to the "Deployment & Operations" section of the official Apache Flink documentation.
at org.apache.flink.yarn.cli.FallbackYarnSessionCli.isActive(FallbackYarnSessionCli.java:59)
at org.apache.flink.client.cli.CliFrontend.validateAndGetActiveCommandLine(CliFrontend.java:1072)
at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:186)
at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:901)
at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:974)
at org.apache.flink.runtime.security.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30)
at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:974)
FLINK缺少hadoop的连接jar包,或者在hadoop环境下配置HADOOP_CLASSPATH的路径
最后
以上就是笨笨乌冬面最近收集整理的关于flink启动错误Executor found. Please make sure to export the HADOOP_CLASSPATH environment的全部内容,更多相关flink启动错误Executor内容请搜索靠谱客的其他文章。
发表评论 取消回复