You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Jon Yeargers <jo...@cedexis.com> on 2016/12/30 14:39:55 UTC

Interesting error message du jour

Using 0.10.2.0-snapshot:

java.lang.IllegalStateException: Incorrect state transition from
ASSIGNING_PARTITIONS to ASSIGNING_PARTITIONS

        at
org.apache.kafka.streams.processor.internals.StreamThread.setState(StreamThread.java:163)

        at
org.apache.kafka.streams.processor.internals.StreamThread.setStateWhenNotInPendingShutdown(StreamThread.java:175)

        at
org.apache.kafka.streams.processor.internals.StreamThread.access$200(StreamThread.java:71)

        at
org.apache.kafka.streams.processor.internals.StreamThread$1.onPartitionsAssigned(StreamThread.java:234)

        at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:230)

        at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:314)

        at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:278)

        at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:261)

        at
org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1039)

        at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1004)

        at
org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:569)

        at
org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:358)

Re: Interesting error message du jour

Posted by Jon Yeargers <jo...@cedexis.com>.

K - so no big deal.

TY

On Fri, Dec 30, 2016 at 12:13 PM, Ewen Cheslack-Postava <ew...@confluent.io>
wrote:

> Jon,
>
> This looks the same as https://issues.apache.org/jira/browse/KAFKA-4563,
> although for a different invalid transition. The temporary fix suggested
> there is to simply convert the exception to log a warning, which should be
> a pretty trivial patch against trunk. It seems there are some transitions
> that haven't fully been thought through even if they may actually be valid,
> so patching this for now may be the easiest way to unblock your
> development.
>
> -Ewen
>
> On Fri, Dec 30, 2016 at 9:45 AM, Jon Yeargers <jo...@cedexis.com>
> wrote:
>
> > Attaching the debug log
> >
> > On Fri, Dec 30, 2016 at 6:39 AM, Jon Yeargers <jo...@cedexis.com>
> > wrote:
> >
> >> Using 0.10.2.0-snapshot:
> >>
> >> java.lang.IllegalStateException: Incorrect state transition from
> >> ASSIGNING_PARTITIONS to ASSIGNING_PARTITIONS
> >>
> >>         at org.apache.kafka.streams.processor.internals.StreamThread.
> >> setState(StreamThread.java:163)
> >>
> >>         at org.apache.kafka.streams.processor.internals.StreamThread.se
> >> tStateWhenNotInPendingShutdown(StreamThread.java:175)
> >>
> >>         at org.apache.kafka.streams.processor.internals.StreamThread.
> >> access$200(StreamThread.java:71)
> >>
> >>         at org.apache.kafka.streams.processor.internals.StreamThread$1.
> >> onPartitionsAssigned(StreamThread.java:234)
> >>
> >>         at org.apache.kafka.clients.consumer.internals.ConsumerCoordina
> >> tor.onJoinComplete(ConsumerCoordinator.java:230)
> >>
> >>         at org.apache.kafka.clients.consumer.internals.AbstractCoordina
> >> tor.joinGroupIfNeeded(AbstractCoordinator.java:314)
> >>
> >>         at org.apache.kafka.clients.consumer.internals.AbstractCoordina
> >> tor.ensureActiveGroup(AbstractCoordinator.java:278)
> >>
> >>         at org.apache.kafka.clients.consumer.internals.ConsumerCoordina
> >> tor.poll(ConsumerCoordinator.java:261)
> >>
> >>         at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(
> >> KafkaConsumer.java:1039)
> >>
> >>         at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaCo
> >> nsumer.java:1004)
> >>
> >>         at org.apache.kafka.streams.processor.internals.StreamThread.
> >> runLoop(StreamThread.java:569)
> >>
> >>         at org.apache.kafka.streams.processor.internals.StreamThread.
> >> run(StreamThread.java:358)
> >>
> >
> >
>

Re: Interesting error message du jour

Posted by Ewen Cheslack-Postava <ew...@confluent.io>.

Jon,

This looks the same as https://issues.apache.org/jira/browse/KAFKA-4563,
although for a different invalid transition. The temporary fix suggested
there is to simply convert the exception to log a warning, which should be
a pretty trivial patch against trunk. It seems there are some transitions
that haven't fully been thought through even if they may actually be valid,
so patching this for now may be the easiest way to unblock your development.

-Ewen

On Fri, Dec 30, 2016 at 9:45 AM, Jon Yeargers <jo...@cedexis.com>
wrote:

> Attaching the debug log
>
> On Fri, Dec 30, 2016 at 6:39 AM, Jon Yeargers <jo...@cedexis.com>
> wrote:
>
>> Using 0.10.2.0-snapshot:
>>
>> java.lang.IllegalStateException: Incorrect state transition from
>> ASSIGNING_PARTITIONS to ASSIGNING_PARTITIONS
>>
>>         at org.apache.kafka.streams.processor.internals.StreamThread.
>> setState(StreamThread.java:163)
>>
>>         at org.apache.kafka.streams.processor.internals.StreamThread.se
>> tStateWhenNotInPendingShutdown(StreamThread.java:175)
>>
>>         at org.apache.kafka.streams.processor.internals.StreamThread.
>> access$200(StreamThread.java:71)
>>
>>         at org.apache.kafka.streams.processor.internals.StreamThread$1.
>> onPartitionsAssigned(StreamThread.java:234)
>>
>>         at org.apache.kafka.clients.consumer.internals.ConsumerCoordina
>> tor.onJoinComplete(ConsumerCoordinator.java:230)
>>
>>         at org.apache.kafka.clients.consumer.internals.AbstractCoordina
>> tor.joinGroupIfNeeded(AbstractCoordinator.java:314)
>>
>>         at org.apache.kafka.clients.consumer.internals.AbstractCoordina
>> tor.ensureActiveGroup(AbstractCoordinator.java:278)
>>
>>         at org.apache.kafka.clients.consumer.internals.ConsumerCoordina
>> tor.poll(ConsumerCoordinator.java:261)
>>
>>         at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(
>> KafkaConsumer.java:1039)
>>
>>         at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaCo
>> nsumer.java:1004)
>>
>>         at org.apache.kafka.streams.processor.internals.StreamThread.
>> runLoop(StreamThread.java:569)
>>
>>         at org.apache.kafka.streams.processor.internals.StreamThread.
>> run(StreamThread.java:358)
>>
>
>

Re: Interesting error message du jour

Posted by Jon Yeargers <jo...@cedexis.com>.

Attaching the debug log

On Fri, Dec 30, 2016 at 6:39 AM, Jon Yeargers <jo...@cedexis.com>
wrote:

> Using 0.10.2.0-snapshot:
>
> java.lang.IllegalStateException: Incorrect state transition from
> ASSIGNING_PARTITIONS to ASSIGNING_PARTITIONS
>
>         at org.apache.kafka.streams.processor.internals.
> StreamThread.setState(StreamThread.java:163)
>
>         at org.apache.kafka.streams.processor.internals.StreamThread.
> setStateWhenNotInPendingShutdown(StreamThread.java:175)
>
>         at org.apache.kafka.streams.processor.internals.
> StreamThread.access$200(StreamThread.java:71)
>
>         at org.apache.kafka.streams.processor.internals.StreamThread$1.
> onPartitionsAssigned(StreamThread.java:234)
>
>         at org.apache.kafka.clients.consumer.internals.
> ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:230)
>
>         at org.apache.kafka.clients.consumer.internals.
> AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:314)
>
>         at org.apache.kafka.clients.consumer.internals.
> AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:278)
>
>         at org.apache.kafka.clients.consumer.internals.
> ConsumerCoordinator.poll(ConsumerCoordinator.java:261)
>
>         at org.apache.kafka.clients.consumer.KafkaConsumer.
> pollOnce(KafkaConsumer.java:1039)
>
>         at org.apache.kafka.clients.consumer.KafkaConsumer.poll(
> KafkaConsumer.java:1004)
>
>         at org.apache.kafka.streams.processor.internals.
> StreamThread.runLoop(StreamThread.java:569)
>
>         at org.apache.kafka.streams.processor.internals.
> StreamThread.run(StreamThread.java:358)
>