You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Navneeth Krishnan <re...@gmail.com> on 2020/12/15 08:30:51 UTC
Punctuate NPE
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
Re: Punctuate NPE
Posted by Navneeth Krishnan <re...@gmail.com>.
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 <bl...@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 <vv...@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
> >
> >
> >
>
Re: Punctuate NPE
Posted by Blake Miller <bl...@gmail.com>.
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 <vv...@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
>
>
>
Re: Punctuate NPE
Posted by John Roesler <vv...@apache.org>.
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