janchilling commented on PR #19750: URL: https://github.com/apache/kafka/pull/19750#issuecomment-2888524888
Hi @cadonna , @mjsax , This is the PR for the bug I found while completing the removal State Updater disabled flow. The tests `testNamedTopologyWithStreamsProtocol` and `testStreamsRebalanceDataWithExtraCopartition` in the `StreamThreadTest` class fail since a StateUpdater thread is left hanging during the teardown process. This is due to the State Updater thread being created before the StreamThread is created in `StreamThread#create` method. From this PR I managed to add a try catch block and manually shutdown the StateUpdater thread, and locally all the test cases passed. Let me if this approach is correct or if any other changes are required. -- 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. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
