Hello everyone.
I’m trying to use Flink Cep library and I want to fetch some events by pattern.
At first I’ve created a simple HelloWorld project. But I have a problem exactly
like it described here:
https://stackoverflow.com/questions/39575991/flink-cep-no-results-printed
You can see my code at this page:
https://gist.github.com/Maminspapin/07615706f4ce975eb3cf5f0b407b0644
No actions are heppend at this block:
DataStream<String> alerts = patternStream
.process(new PatternProcessFunction<String, String>() {
@Override
public void processMatch(Map<String, List<String>> map,
Context context, Collector<String> collector)
throws Exception {
String first = map.get("first").get(0);
System.out.println("First: " + first);
}
});
alerts.print();
Can someone help me understand the cause?
Thanks,
Yuri L.
