linliu-code opened a new pull request, #10671: URL: https://github.com/apache/hudi/pull/10671
### Change Logs `KafkaTestUtils` was created a static variable and only initialized at the start of a test class. A test class may contain multiple test methods. If the zookeeper session expires during the middle, some test methods would fail. Add we did see these failures happened in Azure CI. To solve this problem, we recreated the `KafkaTestUtils` object for each test method instead. ### Impact Fix the session expiration error. ### Risk level (write none, low medium or high below) None. ### Contributor's checklist - [ ] Read through [contributor's guide](https://hudi.apache.org/contribute/how-to-contribute) - [ ] Change Logs and Impact were stated clearly - [ ] Adequate tests were added if applicable - [ ] CI passed -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
