This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 1af18d0211a [fix](audit-loader) Fix the bug that causes audit loader
to fail. (#46119)
1af18d0211a is described below
commit 1af18d0211aafc3b7e151e1d42979e5f96b1e820
Author: lide <[email protected]>
AuthorDate: Tue Dec 31 07:30:00 2024 +0800
[fix](audit-loader) Fix the bug that causes audit loader to fail. (#46119)
Fix the bug that causes audit loader to fail.
Related PR: #45167 #40493
The bug causes audit loader fail as following errors in audit.log.
```
2024-12-27 11:47:47,001 [stream_load]
|Label=audit_log_20241227_114552_856_127_0_0_1_8030|Db=__internal_schema|Table=audit_log|User=|ClientIp=10.0.1.3|Status=Success|Message=OK|Url=http://10.0.1.4:8040/api/_load_error_log?file=__shard_7/error_log_insert_stmt_c24ed0d941f59867-ec08b8542bc2a4a1_c24ed0d941f59867_ec08b8542bc2a4a1|TotalRows=34|LoadedRows=0|FilteredRows=34|UnselectedRows=0|LoadBytes=6887|StartTime=2024-12-27
11:45:52.858|FinishTime=2024-12-27 11:45:52.888
```
The detail error is:
```
curl
http://10.0.1.4:8040/api/_load_error_log?file=__shard_7/error_log_insert_stmt_c24ed0d941f59867-ec08b8542bc2a4a1_c24ed0d941f59867_ec08b8542bc2a4a1
Reason: actual column number in csv file is more than schema column
number.actual number: 29, schema column number: 27; line delimiter: [
], column separator: [ ], result values:
```
Co-authored-by: derenli <[email protected]>
---
.../src/main/java/org/apache/doris/plugin/audit/AuditLoader.java | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
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
index 6aac0364bc0..ee78496cfcb 100644
--- 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,13 +151,11 @@ public class AuditLoader extends Plugin implements
AuditPlugin {
logBuffer.append(event.queryTime).append("\t");
logBuffer.append(event.scanBytes).append("\t");
logBuffer.append(event.scanRows).append("\t");
- logBuffer.append(event.shuffleSendBytes).append("\t");
- logBuffer.append(event.shuffleSendRows).append("\t");
- logBuffer.append(event.scanBytesFromLocalStorage).append("\t");
- logBuffer.append(event.scanBytesFromRemoteStorage).append("\t");
logBuffer.append(event.returnRows).append("\t");
logBuffer.append(event.shuffleSendRows).append("\t");
logBuffer.append(event.shuffleSendBytes).append("\t");
+ logBuffer.append(event.scanBytesFromLocalStorage).append("\t");
+ logBuffer.append(event.scanBytesFromRemoteStorage).append("\t");
logBuffer.append(event.stmtId).append("\t");
logBuffer.append(event.isQuery ? 1 : 0).append("\t");
logBuffer.append(event.isNereids ? 1 : 0).append("\t");
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
