Hi Kostas,
My application didn't have any timestamp extractor nor my events had any
timestamp. Still I was using event time for processing it, probably that's
why it was blocked.
Now I removed the part where I mention timechracteristics as Event time and
it works now.
For example:
Previously:
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
env.getConfig().setAutoWatermarkInterval(1000);
And MyEvent was (No field for timestamp):
public class BAMEvent {
private String id;
private String eventName;
private String eventId;
private List<String> correlationID;
//Getters
//Setters
}
Now:
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
/* env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime); */
env.getConfig().setAutoWatermarkInterval(1000);
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/No-Alerts-with-FinkCEP-tp13333p13405.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
