yanghuaiGit commented on PR #380: URL: https://github.com/apache/doris-flink-connector/pull/380#issuecomment-2099594123
The waitAsyncLoadFinish method logic can insert a BatchRecordBuffer for the blocking queue flushQueue, only to indicate that the previous BatchRecordBuffer was consumed by LoadAsyncExecutor. This does not mean that the data load has finished. LoadAsyncExecutor should remove the flushQueue head data from the blocking queue after the data load has finished -- 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]
