[log](statistics)Add result row count log for statistics internal que…

…ry. (#39556) (#39609) backport: #39556
apache · Aug 20, 2024 · 7c3c5c6 · 7c3c5c6
1 parent a5daa3e
commit 7c3c5c6
Showing 1 changed file with 9 additions and 0 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
@@ -3135,9 +3135,18 @@ public List<ResultRow> executeInternalQuery() {
                 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) {