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 <alaa.abut...@hotmail.com> 于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/ >
