diff --git a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditReporterImpl.java b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditReporterImpl.java index cd716184bc..0346592286 100644 --- a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditReporterImpl.java +++ b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditReporterImpl.java @@ -262,7 +262,7 @@ public synchronized void flush() { * Flush audit data */ public synchronized void flush(long isolateKey) { - if (flushTime.putIfAbsent(isolateKey, Calendar.getInstance().getTimeInMillis()) != null + if (flushTime.putIfAbsent(isolateKey, System.currentTimeMillis()) != null || flushStat.addAndGet(1) > flushStatThreshold) { return; } diff --git a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/send/SenderManager.java b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/send/SenderManager.java index 192e402f63..7b886021a1 100644 --- a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/send/SenderManager.java +++ b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/send/SenderManager.java @@ -269,8 +269,10 @@ public void onMessageReceived(ChannelHandlerContext ctx, byte[] msg) { if (data == null) { LOG.error("Can not find the request id onMessageReceived {},message: {}", requestId, baseCommand.getAuditReply().getMessage()); - for (Map.Entry entry : this.dataMap.entrySet()) { - LOG.debug("Data map key:{},request id:{}", entry.getKey(), requestId); + if (LOG.isDebugEnabled()) { + for (Map.Entry entry : this.dataMap.entrySet()) { + LOG.debug("Data map key:{},request id:{}", entry.getKey(), requestId); + } } return; }