Hi,

In environment configuration when set the time characteristics to
ProcessingTime via setStreamTimeCharacteristic(...) call, I cannot see
watermarks in the Flink UI. I think this is expected, because
watermarks disabled in the source (using Kafka as source)?

Another point here is, can I use Event Time Timers even if I set the
time characteristics to ProcessingTime (via
ctx.timerService().registerEventTimeTimer(...))? As far as I
understood from the documentation, Event Time Timers needs watermarks
which sets  the operator time, so I wonder if I can use event time
timers in case of ProcessingTime selected in the environment? Also
when I set the time characteristics to Event Time can I use both
processing time timers & event time timers without any problem?

Thanks,

Reply via email to