You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2020/03/19 22:00:00 UTC
[jira] [Commented] (KAFKA-9734) Streams IllegalStateException in
trunk during rebalance
[ https://issues.apache.org/jira/browse/KAFKA-9734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17062969#comment-17062969 ]
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
Consolidate ChangelogReader state management inside of StreamThread to avoid having to reason about all execution paths in both StreamThread and TaskManager.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
----------------------------------------------------------------
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:
users@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)