[Fix]Fix losing audit log when statistics queue is full (#47358)

apache · Jan 26, 2025 · 8424b43 · 8424b43
1 parent fec9e9a
commit 8424b43
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadRuntimeStatusMgr.java b/...src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadRuntimeStatusMgr.java
@@ -109,10 +109,11 @@ protected void runAfterCatalogReady() {
     public void submitFinishQueryToAudit(AuditEvent event) {
         queryAuditEventLogWriteLock();
         try {
-            if (queryAuditEventList.size() >= Config.audit_event_log_queue_size) {
-                LOG.warn("audit log event queue size {} is full, this may cause audit log missed."
+            if (queryAuditEventList.size() > Config.audit_event_log_queue_size) {
+                LOG.warn("audit log event queue size {} is full, this may cause audit log missing statistics."
                                 + "you can check whether qps is too high or reset audit_event_log_queue_size",
                         queryAuditEventList.size());
+                Env.getCurrentAuditEventProcessor().handleAuditEvent(event, true);
                 return;
             }
             event.pushToAuditLogQueueTime = System.currentTimeMillis();