gavinchou commented on code in PR #52971:
URL: https://github.com/apache/doris/pull/52971#discussion_r2193185794
##########
fe/fe-core/src/main/java/org/apache/doris/persist/EditLog.java:
##########
@@ -1367,18 +1464,43 @@ private <T extends Writable> void logEdit(short op,
List<T> entries) throws IOEx
if (!batch.getJournalEntities().isEmpty()) {
journal.write(batch);
}
+ txId += entries.size();
}
/**
- * Write an operation to the edit log. Do not sync to persistent store yet.
+ * Asynchronously log an edit by putting it into a blocking queue and
waiting for completion.
+ * This method blocks until the log is written and returns the logId.
*/
- private synchronized long logEdit(short op, Writable writable) {
- if (this.getNumEditStreams() == 0) {
- LOG.error("Fatal Error : no editLog stream", new Exception());
- throw new Error("Fatal Error : no editLog stream");
+ public long logEditWithFlush(short op, Writable writable) {
Review Comment:
naming `logWithQueue()`
--
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]
