You must specify the full class name, in this case `org.example.WordCount`, for the `--class` argument.
On Fri, Jan 19, 2018 at 9:35 AM, Jesse Lacika <je...@odyn.ai> wrote: > I feel like this is probably the simplest thing, but I can't seem to > figure it out, and I've searched and searched and can't find the answer, so > I thought I'd try the mailing list. I'm using maven to build the sample > flink project using the scala API as described here: > > https://ci.apache.org/projects/flink/flink-docs- > release-1.4/quickstart/scala_api_quickstart.html > > I've successfully built the project exactly as described. Now how do I run > it? > > Everything I've tried so far fails. For example: > > $ ./bin/flink run --class WordCount ~/src/flink-gelly-test-maven/ > 44/target/44-1.0-SNAPSHOT.jar > > ------------------------------------------------------------ > The program finished with the following exception: > > org.apache.flink.client.program.ProgramInvocationException: The program's > entry point class 'WordCount' was not found in the jar file. > at org.apache.flink.client.program.PackagedProgram. > loadMainClass(PackagedProgram.java:613) > at org.apache.flink.client.program.PackagedProgram.<init> > (PackagedProgram.java:197) > at org.apache.flink.client.CliFrontend.buildProgram( > CliFrontend.java:866) > at org.apache.flink.client.CliFrontend.run(CliFrontend.java:252) > at org.apache.flink.client.CliFrontend.parseParameters( > CliFrontend.java:1054) > at org.apache.flink.client.CliFrontend$1.call( > CliFrontend.java:1101) > at org.apache.flink.client.CliFrontend$1.call( > CliFrontend.java:1098) > at java.security.AccessController.doPrivileged(Native Method) > at javax.security.auth.Subject.doAs(Subject.java:422) > at org.apache.hadoop.security.UserGroupInformation.doAs( > UserGroupInformation.java:1807) > at org.apache.flink.runtime.security.HadoopSecurityContext. > runSecured(HadoopSecurityContext.java:41) > at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1098) > Caused by: java.lang.ClassNotFoundException: WordCount > at java.net.URLClassLoader.findClass(URLClassLoader.java:381) > at java.lang.ClassLoader.loadClass(ClassLoader.java:424) > at java.lang.ClassLoader.loadClass(ClassLoader.java:357) > at java.lang.Class.forName0(Native Method) > at java.lang.Class.forName(Class.java:348) > at org.apache.flink.client.program.PackagedProgram. > loadMainClass(PackagedProgram.java:610) > ... 11 more > > What am I doing wrong here? > > Thanks, > Jesse >
