kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ewen Cheslack-Postava <e...@confluent.io>
Subject Re: Interesting error message du jour
Date Fri, 30 Dec 2016 20:13:31 GMT
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