flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stephan Ewen <se...@apache.org>
Subject Re: Cluster installation gives java.lang.NoClassDefFoundError for everything
Date Mon, 09 Nov 2015 15:13:39 GMT
The distributed "start-cluster.sh" script works only, if the code is
accessible under the same path on all machines, which must be the same path
as on the machine where you invoke the script.
Otherwise the paths for remote shell commands will be wrong, and the
classpaths will be wrong as a result. That means none of the Flink classes
are in the JVM classpath.

I don't think any of these scripts evaluate a "FLINK_HOME" variable.

Can you try and make sure that Flink is on all machines under the same
directory structure, and that you start it from there?

On Mon, Nov 9, 2015 at 2:32 PM, Camelia Elena Ciolac <camelia@chalmers.se>
wrote:

> Hello,
>
> I am configuring Flink to run on a cluster with NFS.
> I have the Flink 0.9.1 distribution in some path in NFS and I added that
> path in ~/.bashrc as FLINK_HOME, and also included the $FLINK_HOME/lib
> folder to $PATH.
> I have the slaves file and the yaml file configured correctly with the
> nodes involved.
>
> Still, when I run the following command I get the following errors:
>
> $FLINK_HOME/bin/start-cluster.sh
>
> (tried also
> cd $FLINK_HOME
> ./bin/start-cluster.sh)
>
> --> in /log/flink-theuser-jobmanager-thenode.out
> Exception in thread "main" java.lang.NoClassDefFoundError:
> org/apache/flink/runtime/jobmanager/JobManager
> Caused by: java.lang.ClassNotFoundException:
> org.apache.flink.runtime.jobmanager.JobManager
>     at java.net.URLClassLoader$1.run(URLClassLoader.java:217)
>     at java.security.AccessController.doPrivileged(Native Method)
>     at java.net.URLClassLoader.findClass(URLClassLoader.java:205)
>     at java.lang.ClassLoader.loadClass(ClassLoader.java:323)
>     at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:294)
>     at java.lang.ClassLoader.loadClass(ClassLoader.java:268)
> Could not find the main class:
> org.apache.flink.runtime.jobmanager.JobManager. Program will exit.
>
> -->in /log/flink-theuser-taskmanager-theslavenode.out
> Exception in thread "main" java.lang.NoClassDefFoundError:
> org/apache/flink/runtime/taskmanager/TaskManager
> Caused by: java.lang.ClassNotFoundException:
> org.apache.flink.runtime.taskmanager.TaskManager
>     at java.net.URLClassLoader$1.run(URLClassLoader.java:217)
>     at java.security.AccessController.doPrivileged(Native Method)
>     at java.net.URLClassLoader.findClass(URLClassLoader.java:205)
>     at java.lang.ClassLoader.loadClass(ClassLoader.java:323)
>     at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:294)
>     at java.lang.ClassLoader.loadClass(ClassLoader.java:268)
> Could not find the main class:
> org.apache.flink.runtime.taskmanager.TaskManager. Program will exit.
>
>
> And lastly, in my script I have the run of a job which gives:
>
> Exception in thread "main" java.lang.NoClassDefFoundError:
> org/apache/flink/client/CliFrontend
> Caused by: java.lang.ClassNotFoundException:
> org.apache.flink.client.CliFrontend
>     at java.net.URLClassLoader$1.run(URLClassLoader.java:217)
>     at java.security.AccessController.doPrivileged(Native Method)
>     at java.net.URLClassLoader.findClass(URLClassLoader.java:205)
>     at java.lang.ClassLoader.loadClass(ClassLoader.java:323)
>     at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:294)
>     at java.lang.ClassLoader.loadClass(ClassLoader.java:268)
> Could not find the main class: org.apache.flink.client.CliFrontend.
> Program will exit.
>
> What could be the cause and which is the solution?
>
> Looking forward to your answer as soon as possible.
> Many thanks,
> Camelia
>
>

Mime
View raw message