You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Jesse Lacika <je...@odyn.ai> on 2018/01/19 17:35:19 UTC
how to run flink project built with maven
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
Re: how to run flink project built with maven
Posted by Jesse Lacika <je...@odyn.ai>.
Yep, that's it, so simple... Thanks!
On Fri, Jan 19, 2018 at 12:53 PM, Eron Wright <er...@gmail.com> wrote:
> 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/4
>> 4/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.loadMainClas
>> s(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(CliFront
>> end.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(UserGro
>> upInformation.java:1807)
>> at org.apache.flink.runtime.security.HadoopSecurityContext.runS
>> ecured(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.loadMainClas
>> s(PackagedProgram.java:610)
>> ... 11 more
>>
>> What am I doing wrong here?
>>
>> Thanks,
>> Jesse
>>
>
>
Re: how to run flink project built with maven
Posted by Eron Wright <er...@gmail.com>.
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
>