Re: error in LocalStreamEnvironment

2019-09-05 Thread Zhu Zhu
Checked the demo and find that its using a quite outdated flink version(0.10.0). And you are trying to run it with Flink 1.7.2. That's why the NoClassDefFound error happens. I'd suggest you try examples in current Flink repo. references: https://ci.apache.org/projects/flink/flink-docs-release-1.9

Re: error in LocalStreamEnvironment

2019-09-05 Thread alaa
thank for your reply but Unfortunately this solution is not suitable -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: error in LocalStreamEnvironment

2019-09-04 Thread Zhu Zhu
Hi alaa, I think this demo is targeting for running in IDE only. The demo runs in *DemoStreamEnvironment* which extends *LocalStreamEnvironment*. And *LocalStreamEnvironment* cannot be used when submitting a program through a client, as the exception says. If you want to run this demo with flink

error in LocalStreamEnvironment

2019-09-04 Thread alaa
Hallo I try to run this example from GitHub https://github.com/dataArtisans/flink-streaming-demo but there was a problem when I try to run it on Flink to see the result on web dashboard Although the code working properly on my Intellj So, how can I solve this problem ?