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
