Hello Kostas, I made the necessary changes and adapted the code to reflect the changes with 1.4-Snapshot. I still have similar behaviour, I can see that the data is there after partitionedinut stream but no alerts are being raised.
I see some info log on my console as follows: INFO o.a.f.a.java.typeutils.TypeExtractor - class com.project.generated.xjc.ReadEventType is not a valid POJO type because not all fields are valid POJO fields. Now one thing to explicitly mention is that, I am receiving string over Kafka topics and then I am deserializing the string to the POJO which is defined using the XSD of the defined event. but i still am not sure how it changes the way alert is being generated. -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/No-Alerts-with-FinkCEP-tp13333p13362.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
