[
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.
> [[email protected]]$ 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)
