waywtdcc commented on code in PR #7075:
URL: https://github.com/apache/hudi/pull/7075#discussion_r1006419928
##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMetadata.java:
##########
@@ -132,6 +132,20 @@ private void clean(String newInstant) {
}
}
+ /**
+ * start a checkpoint commit message.
+ *
+ * @param instant The start commit instant
+ */
+ public void startCommitInstant(String instant) {
Review Comment:
I think the reason why the task is blocked is that it needs to be done when
committing instant, not running instant. But before, there was no distinction
between running instant and commiting instant. Instead, inflight is used to
represent the running instant and commiting instant states, which is not
accurate enough.
--
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]
