[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Cannot run example on EMR

I am trying to launch a Flink cluster on EMR.  I am following directions

- I created a cluster with emr-5.16.0 - Hadoop 2.8.4
- I SSH'd into the master node,
downloaded flink-1.6.0-bin-hadoop28-scala_2.11.tgz
- I tried to run HADOOP_CONF_DIR=/etc/hadoop/conf ./bin/flink run -m
yarn-cluster -yn 1 examples/streaming/WordCount.jar and got the an error:
Caused by: java.lang.ClassNotFoundException:

I also get the same error when trying to launch yarn-session.sh

Is anyone able to run 1.6 on EMR and provide me with what I am doing wrong?

Thank you