kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jon Yeargers <jon.yearg...@cedexis.com>
Subject Re: Interesting error message du jour
Date Fri, 30 Dec 2016 22:07:54 GMT
K - so no big deal.

TY

On Fri, Dec 30, 2016 at 12:13 PM, Ewen Cheslack-Postava <ewen@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 <jon.yeargers@cedexis.com>
> wrote:
>
> > Attaching the debug log
> >
> > On Fri, Dec 30, 2016 at 6:39 AM, Jon Yeargers <jon.yeargers@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)
> >>
> >
> >
>

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