gejinzh commented on issue #12820:
URL: https://github.com/apache/hudi/issues/12820#issuecomment-2652748242

   > The commit ack event is designed for instant reuse, when a commit is 
empty, the coordinator can reuse the instant for next commit, but here it 
should be okay, because in the last step of `handleBootstrapEvent`, 
`initInstant(instant)` is invoked and unblock the wrtiers, can you show us the 
detailed logs about the recommit failure?
   
   Hudi source code on 'StreamWriteOperatorCoordinator::handleBootstrapEvent'  
does not send commit ack event;
   
   
![Image](https://github.com/user-attachments/assets/cdfe1fca-0228-4cfc-8713-807f716348d7)
   
   I think may be we can add code 'sendCommitAckEvents(-1L)' 
   
   
   
![Image](https://github.com/user-attachments/assets/517b207e-1b67-4df6-abd7-130d2b0d75cd)
   
   
   Because when a instant is empty and recover from checkpoint, the coordiator 
reuse the instant but does not unblock the writers;  On source code only send 
the commit ack event on 'notifyCheckpointComplete';
   
   
   
![Image](https://github.com/user-attachments/assets/48c3815d-1532-43b3-9996-74df92c48db5)
   
   
   the part log on here not other errors just '[Timeout while waiting for 
instant initialize]'
   
   
   [f.txt](https://github.com/user-attachments/files/18763016/f.txt)


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

Reply via email to