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
