Joy-2000 commented on issue #19215: URL: https://github.com/apache/hudi/issues/19215#issuecomment-4912142913
Are we trying to verify whether the commit during recovery is performed via the `recommit()` method? That method does indeed include restarting the heartbeat. However, in previous tests, I observed that during recovery from a failure, `StreamWriteOperatorCoordinator` only calls `resetToCheckpoint()` to complete the recovery process. Uncommitted instants are committed via the subsequent `notifyCheckpointComplete()` call, a flow in which the heartbeat is not restarted. If we want to standardize the commit process during failover by using the `recommit()` method, could we consider lifting the RLI restrictions related to `restoreEvents` within `resetToCheckpoint`? WDYT? -- 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]
