fix fe code format error

apache · Nov 13, 2024 · 3bcdd01 · 3bcdd01
1 parent e861a57
commit 3bcdd01
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 6 deletions.
diff --git a/be/src/runtime/workload_group/workload_group.cpp b/be/src/runtime/workload_group/workload_group.cpp
@@ -96,7 +96,7 @@ std::string WorkloadGroup::debug_string() const {
             "WorkloadGroup[id = {}, name = {}, version = {}, cpu_share = {}, "
             "total_query_slot_count = {}, "
             "memory_limit = {}, slot_memory_policy = {}, write_buffer_ratio= {}%, "
-            "enable_memory_overcommit = {}, total_mem_used = {},"
+            "enable_memory_overcommit = {}, total_mem_used = {} (write_buffer_size={}),"
             "wg_refresh_interval_memory_growth = {},  mem_used_ratio = {}, spill_low_watermark = "
             "{}, spill_high_watermark = {},cpu_hard_limit = {}, scan_thread_num = "
             "{}, max_remote_scan_thread_num = {}, min_remote_scan_thread_num = {}, "
@@ -106,6 +106,7 @@ std::string WorkloadGroup::debug_string() const {
             PrettyPrinter::print(_memory_limit, TUnit::BYTES), to_string(_slot_mem_policy),
             _load_buffer_ratio, _enable_memory_overcommit ? "true" : "false",
             PrettyPrinter::print(_total_mem_used.load(), TUnit::BYTES),
+            PrettyPrinter::print(_write_buffer_size.load(), TUnit::BYTES),
             PrettyPrinter::print(_wg_refresh_interval_memory_growth.load(), TUnit::BYTES),
             mem_used_ratio, _spill_low_watermark, _spill_high_watermark, cpu_hard_limit(),
             _scan_thread_num, _max_remote_scan_thread_num, _min_remote_scan_thread_num,

diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/SchemaTable.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/SchemaTable.java
@@ -464,7 +464,7 @@ public class SchemaTable extends Table {
                                     .column("QUERY_TYPE",  ScalarType.createVarchar(256))
                                     .column("SPILL_WRITE_BYTES_TO_LOCAL_STORAGE",
                                             ScalarType.createType(PrimitiveType.BIGINT))
-                                    .column("SPILL_READ_BYTES_FROM_LOCAL_STORAGE", 
+                                    .column("SPILL_READ_BYTES_FROM_LOCAL_STORAGE",
                                             ScalarType.createType(PrimitiveType.BIGINT))
                                     .build()))
             .put("active_queries", new SchemaTable(SystemIdGenerator.getNextId(), "active_queries", TableType.SCHEMA,

diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/AuditLogHelper.java b/fe/fe-core/src/main/java/org/apache/doris/qe/AuditLogHelper.java
@@ -204,10 +204,10 @@ private static void logAuditLogImpl(ConnectContext ctx, String origStmt, Stateme
                 .setQueryTime(elapseMs)
                 .setScanBytes(statistics == null ? 0 : statistics.getScanBytes())
                 .setScanRows(statistics == null ? 0 : statistics.getScanRows())
-                .setSpillWriteBytesToLocalStorage (statistics == null ? 0 :
-                        statistics.getSpillWriteBytesToLocalStorage ())
-                .setSpillReadBytesFromLocalStorage (statistics == null ? 0 :
-                        statistics.getSpillReadBytesFromLocalStorage ())
+                .setSpillWriteBytesToLocalStorage(statistics == null ? 0 :
+                        statistics.getSpillWriteBytesToLocalStorage())
+                .setSpillReadBytesFromLocalStorage(statistics == null ? 0 :
+                        statistics.getSpillReadBytesFromLocalStorage())
                 .setCpuTimeMs(statistics == null ? 0 : statistics.getCpuMs())
                 .setPeakMemoryBytes(statistics == null ? 0 : statistics.getMaxPeakMemoryBytes())
                 .setReturnRows(ctx.getReturnRows())