From 7c3c5c67fc082f8677a0cbf6e07880fec6ef5365 Mon Sep 17 00:00:00 2001
From: Jibing-Li <64681310+Jibing-Li@users.noreply.github.com>
Date: Tue, 20 Aug 2024 23:18:48 +0800
Subject: [PATCH] [log](statistics)Add result row count log for statistics
 internal query. (#39556) (#39609)

backport: https://github.com/apache/doris/pull/39556
---
 .../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 2cdb331329..9f349891ce 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) {