Hi Navneeth, I'm sorry for the trouble.
Which version of Streams are you using? Also, this doesn't look like the full stacktrace, since we can't see the NPE itself. Can you share the whole thing? Thanks, -John On Tue, 2020-12-15 at 00:30 -0800, Navneeth Krishnan wrote: > Hi All, > > I have a scheduled function that runs every 10 seconds and in some cases I > see this NPE. Not sure how to debug this issue. Any pointers would really > help. Thanks > > context.schedule(this.scheduleInterval, PunctuationType.STREAM_TIME, > this::flush); > > > 2020-12-15 07:40:14.214 > [userapp-c2db617d-ed40-4c9a-a3b3-e9942c19d28a-StreamThread-4] ERROR > Pipeline - > org.apache.kafka.streams.errors.StreamsException: stream-thread > [userapp-c2db617d-ed40-4c9a-a3b3-e9942c19d28a-StreamThread-4] task [12_16] > Exception caught while punctuating processor 'Window_processor' > at > org.apache.kafka.streams.processor.internals.StreamTask.punctuate(StreamTask.java:760) > ~[kafka-streams-2.6.0.jar!/:?] > at > org.apache.kafka.streams.processor.internals.PunctuationQueue.mayPunctuate(PunctuationQueue.java:54) > ~[kafka-streams-2.6.0.jar!/:?] > at > org.apache.kafka.streams.processor.internals.StreamTask.maybePunctuateStreamTime(StreamTask.java:941) > ~[kafka-streams-2.6.0.jar!/:?] > at > org.apache.kafka.streams.processor.internals.TaskManager.punctuate(TaskManager.java:1066) > ~[kafka-streams-2.6.0.jar!/:?] > at > org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:707) > ~[kafka-streams-2.6.0.jar!/:?] > at > org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:551) > ~[kafka-streams-2.6.0.jar!/:?] > at > org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:510) > ~[kafka-streams-2.6.0.jar!/:?] > > Thanks, > Navneeth
