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 8b2c94fea7b [log](statistics)Add result row count log for statistics
internal query. (#39556) (#39607)
8b2c94fea7b is described below
commit 8b2c94fea7b7f77dcd37716ea3f169dbc7a1d822
Author: Jibing-Li <[email protected]>
AuthorDate: Tue Aug 20 23:18:45 2024 +0800
[log](statistics)Add result row count log for statistics internal query.
(#39556) (#39607)
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 f47121348f8..87b18c8cbfa 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
@@ -2782,9 +2782,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]
