janchilling opened a new pull request, #19889:
URL: https://github.com/apache/kafka/pull/19889

   …n StreamThreadTest fix
   
   Updated the code to start the State Updater Thread only after the Stream 
Thread is started.
   
   Changes done :
   1. Moved the starting of the StateUpdater thread to a new init method in the 
TaskManager.
   2. Called the init of TaskManager in the run method of the StreamThread.
   3. Updated the test cases in the StreamThreadTest to mimic the 
aforementioned behaviour.
   


-- 
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

Reply via email to