Hi Community,

We have the below use case,

   - We have to use EventTime for Windowing (Tumbling Window) and
   Watermarking.
      - We use *TumbingEventTimeWindows* for this
   - We have to continuously emit the results for Window every 1 minute.
      - We are planning to use *ContinousProcessingTimeTrigger* for the
      same.
      - ContinuousProcessingTimeTrigger.of(Time.seconds(60))

However when we execute this job - We face the below Issue.

   - *No Watermark (Watermarks are only available if EventTime is used)*


Could you suggest what should be the right trigger/windowing for the same?
Anything we could be missing?



Regards
Saurabh

Reply via email to