kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Blake Miller <blak3mil...@gmail.com>
Subject Re: Punctuate NPE
Date Fri, 18 Dec 2020 02:27:21 GMT
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 <vvcephei@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
>
>
>

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