gejinzh commented on code in PR #12849:
URL: https://github.com/apache/hudi/pull/12849#discussion_r1961245295
##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java:
##########
@@ -449,6 +449,10 @@ private void handleBootstrapEvent(WriteMetadataEvent
event) {
LOG.warn("Reuse current pending Instant {} with {} operationType, "
+ "ignoring empty bootstrap event.", this.instant,
WriteOperationType.INSERT.value());
reset();
+ if (event.isRestored()) {
Review Comment:
The write task will only be unblocked when creating an instant or sending an
ack event;
This code can only be executed when reusing instant.
When reusing instant, it indicates that there is an inflight instant equal
to ```this.instant``` and no new instant will be created;
Therefore, when the event is restored from the state, we need an ack event
to unblock the write tasks;
I don't know if I have answered your question,I'm not getting the question
very well
--
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]
