Hi, I believe this "timestamp + this.delay" is the signal event timestamp + the allowed lateness which in this case an configuring it as EventTimeSessionSignalTrigger.of(this.lateness.toMilliseconds()); So, if the allowed lateness is 10 seconds and the event arrived at 15:10 the event timer would be called at 15:20 right? It should be the desired behaviour.
Thanks -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Signal-Trigger-tp12509p12521.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.