David,
Thank you again for a reply. It really looks like this situation is happened
because of the parallel instances.
Best,
Yuri L.
>Пятница, 26 февраля 2021, 15:40 +03:00 от Dawid Wysakowicz
>:
>
>Hi,
>What is exactly the problem? Is it that no patterns are being generated?
>Usually
Hello, David.
Yes, I’m using 1.12. And my code is now working. Thank you very much for
your comment.
Yuri L.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi,
What is exactly the problem? Is it that no patterns are being generated?
Usually the problem is in idle parallel instances[1]. You need to have
data flowing in each of the parallel instances for a watermark to
progress. You can also read about it in the aspect of Kafka's partitions[2].
Hello,
I’ve already asked the question today and got the solve:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-CEP-can-t-process-PatternStream-td41722.html
, and it’s clean for me how PatternStream works with ProcessTime.
But I need help again, I can’t write
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 patternStream =
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
