error in LocalStreamEnvironment

[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 ?


<http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/t1965/Screenshot_from_2019-09-04_11-12-32.png>




--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[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 client, I think you can change 

"val env: StreamExecutionEnvironment = DemoStreamEnvironment.env" to be "val env = StreamExecutionEnvironment.getExecutionEnvironment"

in the demo code like TotalArrivalCount.scala.

Thanks,

Zhu Zhu

alaa <[hidden email]> 于2019年9月4日周三 下午5:18写道：

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 ?


<http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/t1965/Screenshot_from_2019-09-04_11-12-32.png>




--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[alaa]

thank for your reply but Unfortunately this solution is not suitable

<http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/t1965/Screenshot_from_2019-09-05_09-09-12.png>



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[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/getting-started/examples/

https://ci.apache.org/projects/flink/flink-docs-release-1.9/getting-started/tutorials/local_setup.html

Thanks,

Zhu Zhu

alaa <[hidden email]> 于2019年9月5日周四 下午3:10写道：

thank for your reply but Unfortunately this solution is not suitable

<http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/t1965/Screenshot_from_2019-09-05_09-09-12.png>



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/