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 <came...@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 > >
