Baki, You can get this message "o.a.k.s.state.internals.WindowKeySchema : Warning: window end time was truncated to Long.MAX"" when your TimeWindowDeserializer is created without a windowSize. There are two constructors for a TimeWindowDeserializer, are you using the one with WindowSize?
https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedDeserializer.java#L46-L55 It calls WindowKeySchema with a Long.MAX_VALUE https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedDeserializer.java#L84-L90 On Mon, May 11, 2020 at 8:33 AM John Roesler <vvcep...@apache.org> wrote: > Hello Baki, > > It looks like option 2 is really what you want. The purpose of the time > window stores is to allow deleting old data when you need to group by a > time dimension, which naturally results in an infinite key space. > > If you don’t want to wait for the final result, can you just not add the > suppression? It’s only purpose is to _not_ emit any data until _after_ the > grace period expires. Without it, streams will still respect the grace > period by updating the result whenever there is late arriving data. > > Lastly, that is a check for overflow. The timestamp is supposed to be a > timestamp in milliseconds since the epoch. If you’re getting an overflow, > it means your time stamps are from the far future. You might want to > manually inspect them. > > I hope this helps, > John > > > On Sun, May 10, 2020, at 05:29, Baki Hayat wrote: > > Hello Friends, > > > > I wrote into stackoverflow but also i am writing here, > > > > I have couple of questions about window operation, grace period and late > > events. > > > > Could you please check my problem about group by with adding time field > as > > a key or window by and group by without time field ? > > > > Here is detail explanation... > > > > > https://urldefense.com/v3/__https://stackoverflow.com/questions/61680407/kafka-streams-groupby-late-event-persistentwindowstore-windowby-with-gra__;!!NCc8flgU!M1JXhEsl1PDFilfVGcXuTiFhBfnyiB9FGoTRYUhWV06V4IYu6vsRKqik-DMtmrIO$ > > >
