Re: Flink Stateful Function: The program's entry point class not found in the jar file

2021-01-06 Thread Le Xu
Thanks Igal the application runs perfectly now! Le On Mon, Jan 4, 2021 at 9:13 AM Igal Shilman wrote: > Hi Le, > > Looking at your pom.xml, you are pointing to the wrong main method here: > > https://github.com/flint-stone/flink-statefun/blob/lx-base/statefun-examples/statefun-flink-datastream-

Re: Flink Stateful Function: The program's entry point class not found in the jar file

2021-01-04 Thread Igal Shilman
Hi Le, Looking at your pom.xml, you are pointing to the wrong main method here: https://github.com/flint-stone/flink-statefun/blob/lx-base/statefun-examples/statefun-flink-datastream-example/pom.xml#L161 You need to change it to your Example class, this should work. On Tue, Dec 29, 2020 at 5:06

Re: Flink Stateful Function: The program's entry point class not found in the jar file

2020-12-28 Thread Le Xu
Hi Igal: Thanks for pointing that out. I was able to add the dependency in and submit the job. For statefun-greeter example [1] I was able to submit the job to the cluster . But when I try out the statefun-data-stream example [2] I got the complaints saying that "There are no ingress defined" (I'm

Re: Flink Stateful Function: The program's entry point class not found in the jar file

2020-12-28 Thread Igal Shilman
Hi Le, Indeed you have added the dependency correctly. But the resulting artifact doesn't contain the dependencies. You need to create a jar with dependencies ( via [1] or [2]) Take a look at [3] for a usage example of the maven shade plugin. I hope this helps, Igal. [1] https://maven.apache.org/

Re: Flink Stateful Function: The program's entry point class not found in the jar file

2020-12-26 Thread Le Xu
Thanks Igal! I might be missing something here. I did place statefun-flink-distribution as part of my dependency in the pom (see line 46 at [1]). Is there a correct way to include the jar? I'm having the same problem across many examples I'm running. [1] https://gist.github.com/flint-stone/059f00

Re: Flink Stateful Function: The program's entry point class not found in the jar file

2020-12-26 Thread Igal Shilman
Hello :-) It seems like in your attached pom you are not bundling the dependencies. Check out the docs here [1]. [1] https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.2/deployment-and-operations/packaging.html#flink-jar On Wed, Dec 23, 2020 at 3:07 AM Le Xu wrote: > Hello! >

Flink Stateful Function: The program's entry point class not found in the jar file

2020-12-22 Thread Le Xu
Hello! I'm trying to deploy a Flink stateful function as a flink jar and I followed the instruction here . However I'm getting the error saying that the program entry point class was not found in the jar even after I added the dependency in my pom. Running