linguoxuan commented on PR #2463: URL: https://github.com/apache/fluss/pull/2463#issuecomment-3794131143
Hi, @luoyuxia. Can you take a look if you have time? The failure notification mechanism works as follows: when a Reader encounters an unrecoverable exception, it sends a FailedTieringEvent to the Enumerator, which then broadcasts a TableTieringFailedEvent to all Readers; upon receiving this event, each Reader clean up the state and emits a failure marker through the data stream to notify the downstream Committer to clean up the state. -- 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]
