This is an automated email from the ASF dual-hosted git repository.
yangzhg pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
The following commit(s) were added to refs/heads/master by this push:
new aa4f46c [Enhancement]Use add method instead of put method to avoid
query being stuck when event queue is full (#5310)
aa4f46c is described below
commit aa4f46c3490fde0f72494322ecc594915c16a0fc
Author: caiconghui <[email protected]>
AuthorDate: Thu Feb 18 10:36:55 2021 +0800
[Enhancement]Use add method instead of put method to avoid query being
stuck when event queue is full (#5310)
Co-authored-by: caiconghui [蔡聪辉] <[email protected]>
---
.../src/main/java/org/apache/doris/qe/AuditEventProcessor.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/qe/AuditEventProcessor.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/AuditEventProcessor.java
index a648dc9..64c1609 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/AuditEventProcessor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/AuditEventProcessor.java
@@ -73,9 +73,9 @@ public class AuditEventProcessor {
public void handleAuditEvent(AuditEvent auditEvent) {
try {
- eventQueue.put(auditEvent);
- } catch (InterruptedException e) {
- LOG.debug("encounter exception when handle audit event, ignore",
e);
+ eventQueue.add(auditEvent);
+ } catch (Exception e) {
+ LOG.warn("encounter exception when handle audit event, ignore", e);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
