Lukasz Gajowy created BEAM-7440:
-----------------------------------
Summary: Cannot setup flink 1.8 on dataproc (testing
infrastructure).
Key: BEAM-7440
URL: https://issues.apache.org/jira/browse/BEAM-7440
Project: Beam
Issue Type: Bug
Components: testing
Reporter: Lukasz Gajowy
Since flink 1.8 I get the following error while setting up Flink Dataproc
cluster:
{code:java}
Error: A JNI error has occurred, please check your installation and try again
Exception in thread "main" java.lang.NoClassDefFoundError:
org/apache/hadoop/yarn/exceptions/YarnException
at java.lang.Class.getDeclaredMethods0(Native Method)
at java.lang.Class.privateGetDeclaredMethods(Class.java:2701)
at java.lang.Class.privateGetMethodRecursive(Class.java:3048)
at java.lang.Class.getMethod0(Class.java:3018)
at java.lang.Class.getMethod(Class.java:1784)
at sun.launcher.LauncherHelper.validateMainClass(LauncherHelper.java:544)
at sun.launcher.LauncherHelper.checkAndLoadMain(LauncherHelper.java:526)
Caused by: java.lang.ClassNotFoundException:
org.apache.hadoop.yarn.exceptions.YarnException
at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
... 7 more{code}
It happens when yarn is started on Dataproc (possibly conflict of dependencies
or missing ones).
I used this image:
{code:java}
http://archive.apache.org/dist/flink/flink-1.8.0/flink-1.8.0-bin-scala_2.11.tgz
{code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)