This is an automated email from the ASF dual-hosted git repository.
lijibing 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 7c3c5c67fc0 [log](statistics)Add result row count log for statistics
internal query. (#39556) (#39609)
7c3c5c67fc0 is described below
commit 7c3c5c67fc082f8677a0cbf6e07880fec6ef5365
Author: Jibing-Li <[email protected]>
AuthorDate: Tue Aug 20 23:18:48 2024 +0800
[log](statistics)Add result row count log for statistics internal query.
(#39556) (#39609)
backport: https://github.com/apache/doris/pull/39556
---
fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java | 9 +++++++++
1 file changed, 9 insertions(+)
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 2cdb3313294..9f349891ce3 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
@@ -3135,9 +3135,18 @@ public class StmtExecutor {
while (true) {
batch = coord.getNext();
if (batch == null || batch.isEos()) {
+ 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());
+ }
resultRows.addAll(convertResultBatchToResultRows(batch.getBatch()));
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("Result size for query {} is currently
{}",
+ DebugUtil.printId(queryId),
resultRows.size());
+ }
}
}
} catch (Exception e) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
