Expected behaviour of windows

2017-01-22 Thread Abdul Salam Shaikh
Hi, I needed some clarity on the behaviour of the windows for my use case. I have defined my stream as follows: env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime); * env.setParallelism(1);* DataStream live = env.addSource(new JsonTestSource()); DataStre

Re: machine learning choice

2017-01-22 Thread Andrew Hoblitzell
What is your use case? What algorithms do you plan on running? > On Jan 22, 2017, at 4:46 AM, community tech wrote: > > Hello, > > Flink or Spark, which is the better choice for machine learning? > > Thanks.

accessing flink HA cluster with scala shell/zeppelin notebook

2017-01-22 Thread Maciek Próchniak
Hi, I have standalone Flink cluster configured with HA setting (i.e. with zookeeper recovery). How should I access it remotely, e.g. with Zeppelin notebook or scala shell? There are settings for host/port, but with HA setting they are not fixed - if I check which is *current leader* host and

machine learning choice

2017-01-22 Thread community tech
Hello, Flink or Spark, which is the better choice for machine learning? Thanks.