2

apache · Dec 1, 2024 · 2fd3230 · 2fd3230
1 parent 481472b
commit 2fd3230
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 12 deletions.
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
@@ -137,14 +137,6 @@ public class InternalSchema {
         AUDIT_SCHEMA
                 .add(new ColumnDef("scan_bytes", TypeDef.create(PrimitiveType.BIGINT), ColumnNullableType.NULLABLE));
         AUDIT_SCHEMA.add(new ColumnDef("scan_rows", TypeDef.create(PrimitiveType.BIGINT), ColumnNullableType.NULLABLE));
-        AUDIT_SCHEMA.add(new ColumnDef("local_scan_bytes",
-                TypeDef.create(PrimitiveType.BIGINT), ColumnNullableType.NULLABLE));
-        AUDIT_SCHEMA.add(new ColumnDef("remote_scan_bytes",
-                TypeDef.create(PrimitiveType.BIGINT), ColumnNullableType.NULLABLE));
-        AUDIT_SCHEMA.add(new ColumnDef("shuffle_bytes",
-                TypeDef.create(PrimitiveType.BIGINT), ColumnNullableType.NULLABLE));
-        AUDIT_SCHEMA.add(new ColumnDef("shuffle_rows",
-                TypeDef.create(PrimitiveType.BIGINT), ColumnNullableType.NULLABLE));
         AUDIT_SCHEMA
                 .add(new ColumnDef("return_rows", TypeDef.create(PrimitiveType.BIGINT), ColumnNullableType.NULLABLE));
         AUDIT_SCHEMA

diff --git a/fe/fe-core/src/main/java/org/apache/doris/plugin/audit/AuditLoader.java b/fe/fe-core/src/main/java/org/apache/doris/plugin/audit/AuditLoader.java
@@ -151,10 +151,6 @@ private void fillLogBuffer(AuditEvent event, StringBuilder logBuffer) {
         logBuffer.append(event.queryTime).append("\t");
         logBuffer.append(event.scanBytes).append("\t");
         logBuffer.append(event.scanRows).append("\t");
-        logBuffer.append(event.scanBytesFromLocalStorage).append("\t");
-        logBuffer.append(event.scanBytesFromRemoteStorage).append("\t");
-        logBuffer.append(event.shuffleSendBytes).append("\t");
-        logBuffer.append(event.shuffleSendRows).append("\t");
         logBuffer.append(event.returnRows).append("\t");
         logBuffer.append(event.shuffleSendRows).append("\t");
         logBuffer.append(event.shuffleSendBytes).append("\t");