Hi Olga, have you copied the flink-gelly jar to your TaskManagers? See the instructions in [1] on how you can make the gelly classes available during execution and let us know if you have any problems.
Best, -Vasia, [1]: https://ci.apache.org/projects/flink/flink-docs-master/dev/cluster_execution.html#linking-with-modules-not-contained-in-the-binary-distribution On 28 September 2016 at 20:58, Olga Golovneva <melcha...@gmail.com> wrote: > Hi devs, > > I'm trying to run Gelly ClusteringCoefficient example on a cluster using > this command: > > flink run -C > file://home/ubuntu/flink/flink-libraries/flink-gelly/ > target/flink-gelly_2.10-1.2-SNAPSHOT.jar > -c org.apache.flink.graph.examples.ClusteringCoefficient > flink-gelly-examples_2.10-1.2-SNAPSHOT.jar > > and get the following ClassNotFoundException: > > ------------------------------------------------------------ > > The program finished with the following exception: > > > java.lang.RuntimeException: Could not look up the main(String[]) method > from the class org.apache.flink.graph.examples.ClusteringCoefficient: > org/apache/flink/graph/GraphAnalytic > > at > org.apache.flink.client.program.PackagedProgram. > hasMainMethod(PackagedProgram.java:478) > > at > org.apache.flink.client.program.PackagedProgram.<init> > (PackagedProgram.java:216) > > at org.apache.flink.client.CliFrontend.buildProgram(CliFrontend.java:829) > > at org.apache.flink.client.CliFrontend.run(CliFrontend.java:222) > > at > org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1002) > > at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1045) > > Caused by: java.lang.NoClassDefFoundError: > org/apache/flink/graph/GraphAnalytic > > at java.lang.Class.getDeclaredMethods0(Native Method) > > at java.lang.Class.privateGetDeclaredMethods(Class.java:2625) > > at java.lang.Class.getMethod0(Class.java:2866) > > at java.lang.Class.getMethod(Class.java:1676) > > at > org.apache.flink.client.program.PackagedProgram. > hasMainMethod(PackagedProgram.java:473) > > ... 5 more > > Caused by: java.lang.ClassNotFoundException: > org.apache.flink.graph.GraphAnalytic > > at java.net.URLClassLoader$1.run(URLClassLoader.java:366) > > at java.net.URLClassLoader$1.run(URLClassLoader.java:355) > > at java.security.AccessController.doPrivileged(Native Method) > > at java.net.URLClassLoader.findClass(URLClassLoader.java:354) > > at java.lang.ClassLoader.loadClass(ClassLoader.java:425) > > at java.lang.ClassLoader.loadClass(ClassLoader.java:358) > > ... 10 more > > __________________ > > I got similar Exceptions for other examples in Gelly library, only the > missing methods are different. Perhaps someone more knowledgeable could > kindly help? Where should I look for org.apache.flink.graph.GraphAnalytic? > I thought it should be in flink-gelly_2.10-1.2-SNAPSHOT.jar, but it does > not work > > Thank you, > Olga >