Queryable state formal release plan

2019-05-19 Thread Praveen Chandna
Hi As the Queryable state is in the Beta state, Can you Please confirm the plan for the formal release of the feature Queryable state. Is there any timeline by when this would be added to Flink. Thanks !!! /// Regards Praveen Chandna Product Owner, Mobile +91 9873597204 | ECN: 2864

Re: Propagating delta from window upon trigger

2019-05-19 Thread Congxian Qiu
Hi, Nikhil Window will emit all state to downstream. Can you clear the state while triggering? Nikhil Goyal 于2019年5月19日 周日01:03写道: > I have window of 1 hour and trigger of 5 min. I want to know if every 5 > min Flink is writing the entire window or only the keys which changed. > > On Sat, May 18,

Apache Flink - How to pass configuration params in the flink-config.yaml file to local execution environment

2019-05-19 Thread M Singh
Hey Flink Folks: I was trying to find out how can pass the params in the flink-config.yaml file to a application running in local env. Can I create a flink-config.yaml file and include it in the class path ? Or can I pass the parameters via the parameter tool ? Please let me know if there is an

Possilby very slow keyBy in program with no parallelism

2019-05-19 Thread Theo Diefenthal
Hi, I wrote a small Flink program on a yarn cluster (128GB RAM, 8 core Xeon CPU for each node) essentially reading messages from kafka and applying a simple CEP rule on those messages. The program is expected to have a parallelism of 1 for input as my test kafka topic has only 1 partition.

Re: Flink ML Use cases

2019-05-19 Thread Abhishek Singh
Thanks again for the above resources. I went through the project and also ran the example on my system to get a grasp of the architecture. However, this project does not use Flink ML in it at all. Also, after having done enough research on Flink ML, I also found that it does not let us persist t