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
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,
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
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.
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