kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ewen Cheslack-Postava (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-4563) State transitions error PARTITIONS_REVOKED to NOT_RUNNING
Date Mon, 16 Jan 2017 05:20:27 GMT

    [ https://issues.apache.org/jira/browse/KAFKA-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823473#comment-15823473
] 

Ewen Cheslack-Postava commented on KAFKA-4563:
----------------------------------------------

[~enothereska] https://github.com/apache/kafka/pull/2283 "fixed" this temporarily. Should
this still be scheduled for 0.10.2.0 or is this lower priority since these checks were introduced
recently and in some cases the checks seem to be invalid?

> State transitions error PARTITIONS_REVOKED to NOT_RUNNING
> ---------------------------------------------------------
>
>                 Key: KAFKA-4563
>                 URL: https://issues.apache.org/jira/browse/KAFKA-4563
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams
>    Affects Versions: 0.10.2.0
>            Reporter: Eno Thereska
>            Assignee: Eno Thereska
>             Fix For: 0.10.2.0
>
>
> When starting and stopping streams quickly, the following exception is thrown:
> java.lang.IllegalStateException: Incorrect state transition from PARTITIONS_REVOKED to
NOT_RUNNING
>     at org.apache.kafka.streams.processor.internals.StreamThread.setState(StreamThread.java:164)
>     at org.apache.kafka.streams.processor.internals.StreamThread.shutdown(StreamThread.java:414)
>     at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:366)
> A temporary fix is to convert the exception into a warning, since clearly not all state
transitions are thought through yet.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message