1032851561 commented on issue #8087: URL: https://github.com/apache/hudi/issues/8087#issuecomment-1478790737
> Thanks, here the question is: why the checkpoint barrier can not cham in earlier? Like in a time point within the range time1 ~ time6 > Thanks, here the question is: why the checkpoint barrier can not cham in earlier? Like in a time point within the range time1 ~ time6 In my case, the first increment queries(start-commint=earilest) products about 1200 `MergeOnReadInputSplit`, the first checkpoint barrier was generated after all the split is sent to `StreamReadOperator`. -- 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]
