JNSimba commented on issue #100: URL: https://github.com/apache/doris-flink-connector/issues/100#issuecomment-1432848516
> When doing checkpoint, method dorisStreamLoad.startLoad() will be invoked and changes pendingLoadFuture, but in checkDone() dorisStreamLoad.getPendingLoadFuture() may get old pendingLoadFuture. Sorry, I didn't understand what you meant. Under normal circumstances, the Interrupt exception in the `checkDone()` method is due to the end of streamload, but it has not reached `dorisStreamLoad.stopLoad()`. When checkpointing, the `snapshotState` method will open a new pendingLoadFuture through `dorisStreamLoad.startLoad`. However, at this time, the `dorisStreamLoad.handlePreCommitResponse` step in the `checkDone` method should not be possible, right? Because `dorisStreamLoad.getPendingLoadFuture().isDone()` is flase? -- 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] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
