stream2000 opened a new pull request, #9175: URL: https://github.com/apache/hudi/pull/9175
… before start new instant ### Change Logs When some sub-tasks failed and global failure triggered, write tasks will be reset and re-deployed. Due to `StreamWriteCoordinator` do not extends `RecreateOnResetOperatorCoordinator`, the coordinator won't be close so the heartbeat thread of last instant will remain in the JVM. The whole process is like: sub tasks failed -> global failure trigged -> coodinator reset write tasks -> write tasks recreate and boostrap -> coordinator handle bootstrap event -> start new instant if don't need to recommit ( thus the last instant heartbeat will remain) ### Impact stop current instant heartbeat before start new instant ### Risk level (write none, low medium or high below) low ### Documentation Update 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: commits-unsubscr...@hudi.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
