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 <[email protected]> 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 > > >
