Skip to content

Commit

Permalink
[HUDI-5412] Send the boostrap event if the JM also rebooted (#7497) (#…
Browse files Browse the repository at this point in the history
…7498)

(cherry picked from commit c637280)
  • Loading branch information
danny0405 committed Dec 19, 2022
1 parent de51917 commit c288a50
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -217,8 +217,9 @@ private void sendBootstrapEvent() {
if (this.currentInstant != null) {
LOG.info("Recover task[{}] for instant [{}] with attemptId [{}]", taskID, this.currentInstant, attemptId);
this.currentInstant = null;
return;
}
return;
// the JM may have also been rebooted, sends the bootstrap event either
}
this.eventGateway.sendEventToCoordinator(WriteMetadataEvent.emptyBootstrap(taskID));
LOG.info("Send bootstrap write metadata event to coordinator, task[{}].", taskID);
Expand Down

0 comments on commit c288a50

Please sign in to comment.