3

Author: morningman

fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/call/CallFlushAuditLogFunc.java

@@ -34,17 +34,17 @@ public class CallFlushAuditLogFunc extends CallFunc {
 
     private UserIdentity user;
 
+    private CallFlushAuditLogFunc(UserIdentity user) {
+        this.user = user;
+    }
+
     public static CallFunc create(UserIdentity user, List<Expression> args) {
         if (!args.isEmpty()) {
             throw new AnalysisException("FLUSH_AUDIT_LOG function requires no parameter");
         }
         return new CallFlushAuditLogFunc(user);
     }
 
-    private CallFlushAuditLogFunc(UserIdentity user) {
-        this.user = user;
-    }
-
     @Override
     public void run() {
         // check priv

fe/fe-core/src/main/java/org/apache/doris/plugin/audit/AuditLoader.java

@@ -85,7 +85,7 @@ public void init(PluginInfo info, PluginContext ctx) throws PluginException {
             // GlobalVariable.audit_plugin_max_batch_bytes.
             this.auditEventQueue = Queues.newLinkedBlockingDeque(100000);
             this.streamLoader = new AuditStreamLoader();
-            this.loadThread = new Thread(new LoadWorker(this.streamLoader), "audit loader thread");
+            this.loadThread = new Thread(new LoadWorker(), "audit loader thread");
             this.loadThread.start();
 
             isInit = true;