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. However, it is not accurate to use inflight to represent
running instant and committing instant instead of recording a state in commit.
--
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]
