python (65.2k questions)
javascript (44.3k questions)
reactjs (22.7k questions)
java (20.8k questions)
c# (17.4k questions)
html (16.3k questions)
r (13.7k questions)
android (13k questions)
Building event based alerting pipeline with Flink
We have a kafka source of events(~5000/sec), and another stream of rules(~5000k/day) created by users for alerting purpose. A rule expires after a day in our system. We need to match each event agains...
Jack
Votes: 0
Answers: 0
Flink 1.14 : Why can't resotore savepoint got error Caused by: org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find Flink job
I'm trying to restore a savepoint which is save to my local tmp folder.However i got below error when i trying to restore it.Do you have any idea about this ?
/home/chinthakasajith/flink-1.14.0$ ./bin...
Sajith Gunarathna
Votes: 0
Answers: 1
Time characteristic in Stateful functions
I understand in general that event time uses Watermarks to make progress in time. In the case of Flink Statefun which is more based on iteration it may be a problem. So my question is if I use the del...
Muralidharan Rajamani
Votes: 0
Answers: 1