Hi Frank,

Is this happening when you are shutting down the app, or is the app shutting 
down unexpectedly?

The state transition error is not the main issue, it's largely a side effect of 
the unexpected transition so the first error is the cause probably. However, I 
can't tell what happened before since a normal shutdown also looks the same. 

Eno
> On 16 Dec 2016, at 11:35, Frank Lyaruu <flya...@gmail.com> wrote:
> 
> Hi people,
> 
> I'm running a Kafka Streams app (trunk build from a few days ago), I see
> this error from time to time:
> 
> Exception in thread "StreamThread-18" java.lang.NullPointerException
> 
> at org.apache.kafka.streams.processor.internals.StreamThread$5.
> apply(StreamThread.java:998)
> at org.apache.kafka.streams.processor.internals.StreamThread.pe
> rformOnAllTasks(StreamThread.java:489)
> at org.apache.kafka.streams.processor.internals.StreamThread.
> closeAllTasks(StreamThread.java:995)
> at org.apache.kafka.streams.processor.internals.StreamThread.sh
> utdownTasksAndState(StreamThread.java:442)
> at org.apache.kafka.streams.processor.internals.StreamThread.
> shutdown(StreamThread.java:387)
> at org.apache.kafka.streams.processor.internals.StreamThread.
> run(StreamThread.java:368)
> 
> 
> After that it spews a bunch of these:
> 
> Exception in thread "StreamThread-13" java.lang.IllegalStateException:
> Incorrect state transition from RUNNING to NOT_RUNNING
> 
> at org.apache.kafka.streams.processor.internals.StreamThread.
> setState(StreamThread.java:163)
> at org.apache.kafka.streams.processor.internals.StreamThread.
> shutdown(StreamThread.java:416)
> 
> I'm now running on multiple instances, before I ran on a single instance, I
> don't think I saw it then.
> 
> regards, Frank

Reply via email to