Hi Yuri, Which Flink version are you using? Is it 1.12? In 1.12 we changed the default TimeCharacteristic to EventTime. Therefore you need watermarks and timestamp[1] for your program to work correctly. If you want to apply your pattern in ProcessingTime you can do:
PatternStream<String> patternStream = CEP.pattern(stream, pattern).inProcessingTime(); Basically you are facing exactly the same problem as described in the stackoverflow entry you posted. Best, Dawid [1] https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/event_timestamps_watermarks.html#generating-watermarks On 26/02/2021 09:18, Люльченко Юрий Николаевич wrote: > 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 > <https://stackoverflow.com/questions/39575991/flink-cep-no-results-printed> > > You can see my code at this > page: https://gist.github.com/Maminspapin/07615706f4ce975eb3cf5f0b407b0644 > <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. >
OpenPGP_signature
Description: OpenPGP digital signature
