Thanks Sendoh. Is there a way to advance watermark even when there are no incoming events. What exactly does setAutoWatermarkInterval do?
Also I don't see the watermark displayed in flink dashboard. Will the watermark advance only when there is data from all consuming kafka topic and partitions? I have 3 topics with 3 partitions in each topic. Thanks. Regards, Navneeth On Tue, Jan 23, 2018 at 9:32 AM, Sendoh <unicorn.bana...@gmail.com> wrote: > Hi, > > you can write your own trigger and window, and implement whatever logic > there. > There are some examples > https://github.com/apache/flink/blob/1875cac03042dad4a4c47b0de8364f > 02fbe457c6/flink-streaming-java/src/main/java/org/apache/ > flink/streaming/api/windowing/triggers/ > > If you don't see any event, it means window is not triggered. > > It would mean Watermark is not increasing. The issue can be the timestamp > is > not extracted correctly. > Or, if you miss the trigger if use the window function doesn't have it. > > Cheers, > > Sendoh > > > > -- > Sent from: http://apache-flink-user-mailing-list-archive.2336050. > n4.nabble.com/ >
