Thanks John & Blake. Will try to recreate the issue and see what's going on.
Regards, Navneeth On Thu, Dec 17, 2020 at 6:27 PM Blake Miller <blak3mil...@gmail.com> wrote: > Navneeth, > > You may need this JVM option: > > -XX:-OmitStackTraceInFastThrow > > as some stack frame information can be optimized away by default by some > JVMs leaving us blind to the real issue. > > HTH > > On Wed, Dec 16, 2020 at 4:15 AM John Roesler <vvcep...@apache.org> wrote: > > > 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 > > > > > > >
