Re: Apache Flink - Relation between stream time characteristic and timer triggers

2019-07-11 Thread M Singh
Thanks Fabian/Xingcan/Yun for all your help.  Mans On Thursday, July 11, 2019, 11:46:42 AM EDT, Fabian Hueske wrote: Hi, ProcessingTime timers are always supportedEventTime timers are only supported for EventTime and IngestionTime Best, Fabian Am Do., 11. Juli 2019 um 17:44 Uhr schrie

Re: Apache Flink - Relation between stream time characteristic and timer triggers

2019-07-11 Thread Fabian Hueske
Hi, ProcessingTime timers are always supported EventTime timers are only supported for EventTime and IngestionTime Best, Fabian Am Do., 11. Juli 2019 um 17:44 Uhr schrieb M Singh : > Thanks Fabian for your response. > > Just to clarify then - regardless of the time characteristics, if a > proce

Re: Apache Flink - Relation between stream time characteristic and timer triggers

2019-07-11 Thread M Singh
Thanks Fabian for your response. Just to clarify then - regardless of the time characteristics, if a processor or window trigger registers with a ProcessingTime  and EventTime  timers - they will all fire when the appropriate watermarks arrive. Thanks again. On Thursday, July 11, 2019, 05:41

Re: Apache Flink - Relation between stream time characteristic and timer triggers

2019-07-11 Thread Fabian Hueske
Hi Mans, IngestionTime is uses the same internal mechanisms as EventTime (record timestamps and watermarks). The difference is that instead of extracting a timestamp from the record (using a custom timestamp extractor & wm assigner), Flink will assign timestamps based on the machine clock of the

Re: Apache Flink - Relation between stream time characteristic and timer triggers

2019-07-10 Thread M Singh
Thanks for your answer Xingcan. Just to clarify - if the characteristic is set to IngestionTime or ProcessingTime, the event time triggers will be ignored and not fire. Mans On Tuesday, July 9, 2019, 04:32:00 PM EDT, Xingcan Cui wrote: Yes, Mans. You can use both processing-time and ev

Re: Apache Flink - Relation between stream time characteristic and timer triggers

2019-07-09 Thread Xingcan Cui
Yes, Mans. You can use both processing-time and event-time timers if you set the time characteristic to event-time. They'll be triggered by their own time semantics, separately. (actually there’s no watermark for processing time) Cheers, Xingcan > On Jul 9, 2019, at 11:40 AM, M Singh wrote: >

Re: Apache Flink - Relation between stream time characteristic and timer triggers

2019-07-09 Thread M Singh
Thanks Yun for your answers. Does this mean that we can use processing and event timers (in processors or triggers) regardless of the time characteristic ?  Also, is possible to use both together and will they both fire at the appropriate watermarks for processing and event times ?   Mans O

Re: Apache Flink - Relation between stream time characteristic and timer triggers

2019-07-08 Thread Yun Gao
Hi, For the three questions, 1. The processing time timer will be trigger. IMO you may think the processing time timer as in parallel with the event time timer. They are processed separately underlying. The processing time timer will be triggered according to the realistic time. 2. I'am

Apache Flink - Relation between stream time characteristic and timer triggers

2019-07-08 Thread M Singh
Hi: I have a few questions about the stream time characteristics: 1. If the time characteristic is set to TimeCharacteristic.EventTime, but the timers in a processor or trigger is set using registerProcessingTimeTimer (or vice versa), then will that timer fire ?   2.  Once the time character is s