You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Kamil Wasilewski (Jira)" <ji...@apache.org> on 2019/10/24 09:49:00 UTC
[jira] [Assigned] (BEAM-7440) Cannot setup flink 1.8 on dataproc
(testing infrastructure).
[ https://issues.apache.org/jira/browse/BEAM-7440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kamil Wasilewski reassigned BEAM-7440:
--------------------------------------
Assignee: Kamil Wasilewski
> 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
> Assignee: Kamil Wasilewski
> Priority: Major
>
> 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
(v8.3.4#803005)