[ https://issues.apache.org/jira/browse/FLINK-19126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189928#comment-17189928 ]
Tang Yan commented on FLINK-19126: ---------------------------------- [~fly_in_gis] [~klion26] Seems still the same error even export HADOOP_CLASSPATH. [yanta@rphf1hsn004 flink-1.11]$ export HADOOP_CLASSPATH='/opt/cloudera/parcels/GPLEXTRAS-6.3.0-1.gplextras6.3.0.p0.1279813/lib/hadoop/lib/*:/opt/cloudera/parcels/CDH/lib/hadoop/lib/*'[yanta@rphf1hsn004 flink-1.11]$ export HADOOP_CLASSPATH='/opt/cloudera/parcels/GPLEXTRAS-6.3.0-1.gplextras6.3.0.p0.1279813/lib/hadoop/lib/*:/opt/cloudera/parcels/CDH/lib/hadoop/lib/*' [yanta@rphf1hsn004 flink-1.11]$ bin/flink run -m yarn-cluster -p 2 -c org.apache.flink.examples.java.wordcount.WordCount examples/batch/WordCount.jar --input hdfs:///user/yanta/aa.txt --output hdfs:///user/yanta/result.txt SLF4J: Class path contains multiple SLF4J bindings.SLF4J: Found binding in [jar:file:/opt/flink-1.11/lib/log4j-slf4j-impl-2.12.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]SLF4J: Found binding in [jar:file:/opt/cloudera/parcels/CDH-6.3.0-1.cdh6.3.0.p0.1279813/jars/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] ------------------------------------------------------------ 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:1090) at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:218) at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:916) at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:992) at org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30) at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:992) > Failed to run job in yarn-cluster mode due to No Executor found. > ---------------------------------------------------------------- > > Key: FLINK-19126 > URL: https://issues.apache.org/jira/browse/FLINK-19126 > Project: Flink > Issue Type: Bug > Components: Deployment / YARN > Affects Versions: 1.11.1 > Reporter: Tang Yan > Priority: Major > > I've build the flink package successfully, but when I run the below command, > it failed to submit the jobs. > [yanta@flink-1.11]$ bin/flink run -m yarn-cluster -p 2 -c > org.apache.flink.examples.java.wordcount.WordCount > examples/batch/WordCount.jar --input hdfs:///user/yanta/aa.txt --output > hdfs:///user/yanta/result.txt > Setting HADOOP_CONF_DIR=/etc/hadoop/conf because no HADOOP_CONF_DIR or > HADOOP_CLASSPATH was set. > ------------------------------------------------------------ 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:1090) > at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:218) at > org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:916) > at > org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:992) > at > org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30) > at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:992) -- This message was sent by Atlassian Jira (v8.3.4#803005)