This is an automated email from the ASF dual-hosted git repository.
lijibing pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new a1898b6de01 [fix](auditlog)Record return row count in audit log for
internal query. (#39616) (#39701)
a1898b6de01 is described below
commit a1898b6de018a010b8cfc231f6025afbdfa7d6d1
Author: Jibing-Li <64681310+jibing...@users.noreply.github.com>
AuthorDate: Wed Aug 21 16:40:24 2024 +0800
[fix](auditlog)Record return row count in audit log for internal query.
(#39616) (#39701)
backport: https://github.com/apache/doris/pull/39616
---
fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
index 87b18c8cbfa..7bb4ee6c2af 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
@@ -2785,9 +2785,12 @@ public class StmtExecutor {
LOG.info("Result rows for query {} is {}",
DebugUtil.printId(queryId), resultRows.size());
return resultRows;
} else {
- if (LOG.isDebugEnabled() && batch.getBatch() != null
&& batch.getBatch().rows != null) {
- LOG.debug("Batch size for query {} is {}",
- DebugUtil.printId(queryId),
batch.getBatch().rows.size());
+ if (batch.getBatch().getRows() != null) {
+
context.updateReturnRows(batch.getBatch().getRows().size());
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("Batch size for query {} is {}",
+ DebugUtil.printId(queryId),
batch.getBatch().rows.size());
+ }
}
resultRows.addAll(convertResultBatchToResultRows(batch.getBatch()));
if (LOG.isDebugEnabled()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
