kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Navneeth Krishnan <reachnavnee...@gmail.com>
Subject Punctuate NPE
Date Tue, 15 Dec 2020 08:30:51 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message