This is an automated email from the ASF dual-hosted git repository.
jacktengg pushed a commit to branch spill_and_reserve
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/spill_and_reserve by this push:
new 2f96cfccf62 fix fe code format
2f96cfccf62 is described below
commit 2f96cfccf6226a590e955daa3b3561308d0ab8ea
Author: jacktengg <[email protected]>
AuthorDate: Wed Nov 13 15:53:04 2024 +0800
fix fe code format
---
fe/fe-core/src/main/java/org/apache/doris/catalog/SchemaTable.java | 6 ++++--
fe/fe-core/src/main/java/org/apache/doris/qe/AuditLogHelper.java | 6 ++++--
.../resource/workloadschedpolicy/WorkloadRuntimeStatusMgr.java | 4 ++--
3 files changed, 10 insertions(+), 6 deletions(-)
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
index cc5b0b19465..d312dbc6c82 100644
--- 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
@@ -462,8 +462,10 @@ public class SchemaTable extends Table {
.column("SHUFFLE_SEND_BYTES",
ScalarType.createType(PrimitiveType.BIGINT))
.column("SHUFFLE_SEND_ROWS",
ScalarType.createType(PrimitiveType.BIGINT))
.column("QUERY_TYPE",
ScalarType.createVarchar(256))
-
.column("SPILL_WRITE_BYTES_TO_LOCAL_STORAGE",
ScalarType.createType(PrimitiveType.BIGINT))
-
.column("SPILL_READ_BYTES_FROM_LOCAL_STORAGE",
ScalarType.createType(PrimitiveType.BIGINT))
+
.column("SPILL_WRITE_BYTES_TO_LOCAL_STORAGE",
+
ScalarType.createType(PrimitiveType.BIGINT))
+
.column("SPILL_READ_BYTES_FROM_LOCAL_STORAGE",
+
ScalarType.createType(PrimitiveType.BIGINT))
.build()))
.put("active_queries", new
SchemaTable(SystemIdGenerator.getNextId(), "active_queries", TableType.SCHEMA,
builder().column("QUERY_ID", ScalarType.createVarchar(256))
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
index cbc410edc19..4801d5e728d 100644
--- 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,8 +204,10 @@ public class AuditLogHelper {
.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())
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadRuntimeStatusMgr.java
b/fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadRuntimeStatusMgr.java
index 32b49346a90..d671e97271a 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadRuntimeStatusMgr.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadRuntimeStatusMgr.java
@@ -228,8 +228,8 @@ public class WorkloadRuntimeStatusMgr extends MasterDaemon {
if (dst.max_peak_memory_bytes < src.max_peak_memory_bytes) {
dst.max_peak_memory_bytes = src.max_peak_memory_bytes;
}
- dst.spill_write_bytes_to_local_storage +=
src.spill_write_bytes_to_local_storage ;
- dst.spill_read_bytes_from_local_storage +=
src.spill_read_bytes_from_local_storage ;
+ dst.spill_write_bytes_to_local_storage +=
src.spill_write_bytes_to_local_storage;
+ dst.spill_read_bytes_from_local_storage +=
src.spill_read_bytes_from_local_storage;
}
private void queryAuditEventLogWriteLock() {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
