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

ASF GitHub Bot commented on KAFKA-9734:
---------------------------------------

vvcephei commented on pull request #8319: KAFKA-9734: Fix IllegalState in 
Streams transit to standby
URL: https://github.com/apache/kafka/pull/8319
 
 
   
 
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


> Streams IllegalStateException in trunk during rebalance
> -------------------------------------------------------
>
>                 Key: KAFKA-9734
>                 URL: https://issues.apache.org/jira/browse/KAFKA-9734
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams
>            Reporter: John Roesler
>            Assignee: John Roesler
>            Priority: Major
>
> I have observed the following exception to kill a thread in the current trunk 
> of Streams:
> {noformat}
> [2020-03-19 07:04:35,206] ERROR 
> [stream-soak-test-e60443b4-aa2d-4107-abf7-ce90407cb70e-StreamThread-1] 
> stream-thread [stream-soak-test-e60443b4-aa    
> 2d-4107-abf7-ce90407cb70e-StreamThread-1] Encountered the following exception 
> during processing and the thread is going to shut down:  
> (org.apache.kafka.streams.processor.internals.StreamThread)
> java.lang.IllegalStateException: The changelog reader is not restoring active 
> tasks while trying to transit to update standby tasks: {}
>         at 
> org.apache.kafka.streams.processor.internals.StoreChangelogReader.transitToUpdateStandby(StoreChangelogReader.java:303)
>                                                                               
>                            
>         at 
> org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:582)
>         at 
> org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:498)
>         at 
> org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:472){noformat}
> Judging from the fact that the standby tasks are reported as an empty set, I 
> think this is just a missed case in the task manager. PR to follow shortly.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to