Are processing-time timers retained in checkpoint & savepoint state and run
if a job is restarted? It's possible that the time at which timer was
intended to trigger at passes while the job is in the middle of being
restarted. Are processing-time timers persisted at all?
Thanks!
--Scott Kidder
Hi,
Flink's batch join API only features a binary join.
However, if the join functions have semantic annotations [1], multiple
binary joins on the same attributes can be executed in a pipelined fashion
without additional shuffles or sorts.
Best, Fabian
[1]
https://ci.apache.org/projects/flink/fl
Does Flink support multi-way join which contains more than two tables such
as
T1⋈T2⋈T3⋈T4?
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Does-Flink-support-multi-way-join-tp10799.html
Sent from the Apache Flink User Mailing List archive.
Anyone has any experience mining a Flink+Kafka stream?
I'm looking for an online analysis framework to apply some classifiers on a
time serie.
Any example of how to integrate Flink with MOA, Samoa, ADAMS, DataSketches
or any other framework is appreciated.
Regards,
Matt
Hi all,
Since both ReducingState and ValueState store a single value, there are
many use cases where both can be used.
When should we use one instead of the other ?
Best regards,
Kien
