(doris) branch master updated: [Fix]Fix losing audit log when statistics queue is full (#47358)

[wangbo]

This is an automated email from the ASF dual-hosted git repository.

wangbo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/master by this push:
     new 8424b4303d6 [Fix]Fix losing audit log when statistics queue is full 
(#47358)
8424b4303d6 is described below

commit 8424b4303d6fb1956e0dab253f3e5c78c5b53efe
Author: wangbo <wan...@selectdb.com>
AuthorDate: Sun Jan 26 16:54:20 2025 +0800

    [Fix]Fix losing audit log when statistics queue is full (#47358)
---
 .../doris/resource/workloadschedpolicy/WorkloadRuntimeStatusMgr.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadRuntimeStatusMgr.java
 
b/fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadRuntimeStatusMgr.java
index 695bf983dc6..bc80cd4506d 100644
--- 
a/fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadRuntimeStatusMgr.java
+++ 
b/fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadRuntimeStatusMgr.java
@@ -109,10 +109,11 @@ public class WorkloadRuntimeStatusMgr extends 
MasterDaemon {
     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();


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org