diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/InternalSchema.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/InternalSchema.java index 7d34876170..5a4934ec2a 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/catalog/InternalSchema.java +++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/InternalSchema.java @@ -68,7 +68,7 @@ public class InternalSchema { // audit table AUDIT_SCHEMA = new ArrayList<>(); AUDIT_SCHEMA.add(new ColumnDef("query_id", TypeDef.createVarchar(48), true)); - AUDIT_SCHEMA.add(new ColumnDef("time", TypeDef.create(PrimitiveType.DATETIME), true)); + AUDIT_SCHEMA.add(new ColumnDef("time", TypeDef.createDatetimeV2(3), true)); AUDIT_SCHEMA.add(new ColumnDef("client_ip", TypeDef.createVarchar(128), true)); AUDIT_SCHEMA.add(new ColumnDef("user", TypeDef.createVarchar(128), true)); AUDIT_SCHEMA.add(new ColumnDef("catalog", TypeDef.createVarchar(128), true)); diff --git a/fe/fe-core/src/main/java/org/apache/doris/plugin/audit/AuditLoaderPlugin.java b/fe/fe-core/src/main/java/org/apache/doris/plugin/audit/AuditLoaderPlugin.java index d8941605c3..f5096d9a8f 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/plugin/audit/AuditLoaderPlugin.java +++ b/fe/fe-core/src/main/java/org/apache/doris/plugin/audit/AuditLoaderPlugin.java @@ -148,7 +148,7 @@ public class AuditLoaderPlugin extends Plugin implements AuditPlugin { private void fillLogBuffer(AuditEvent event, StringBuilder logBuffer) { logBuffer.append(event.queryId).append("\t"); - logBuffer.append(TimeUtils.longToTimeString(event.timestamp)).append("\t"); + logBuffer.append(TimeUtils.longToTimeStringWithms(event.timestamp)).append("\t"); logBuffer.append(event.clientIp).append("\t"); logBuffer.append(event.user).append("\t"); logBuffer.append(event.ctl).append("\t");