You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ja...@apache.org on 2019/05/17 04:41:48 UTC

[incubator-pinot] 01/01: Minor fix for star-tree creation logs

This is an automated email from the ASF dual-hosted git repository.

jackie pushed a commit to branch minor_fix_startree
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git

commit b27799e17c58164feff3ebff70735123d2f26720
Author: Jackie (Xiaotian) Jiang <xa...@linkedin.com>
AuthorDate: Thu May 16 21:41:30 2019 -0700

    Minor fix for star-tree creation logs
---
 .../pinot/core/startree/v2/builder/BaseSingleTreeBuilder.java      | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/pinot-core/src/main/java/org/apache/pinot/core/startree/v2/builder/BaseSingleTreeBuilder.java b/pinot-core/src/main/java/org/apache/pinot/core/startree/v2/builder/BaseSingleTreeBuilder.java
index 13f0ed8..f999e74 100644
--- a/pinot-core/src/main/java/org/apache/pinot/core/startree/v2/builder/BaseSingleTreeBuilder.java
+++ b/pinot-core/src/main/java/org/apache/pinot/core/startree/v2/builder/BaseSingleTreeBuilder.java
@@ -304,7 +304,7 @@ abstract class BaseSingleTreeBuilder implements SingleTreeBuilder {
   public void build()
       throws Exception {
     long startTime = System.currentTimeMillis();
-    LOGGER.info("Start building star-trees with config: {}", _builderConfig);
+    LOGGER.info("Start building star-tree with config: {}", _builderConfig);
 
     int numSegmentRecords = _segment.getSegmentMetadata().getTotalRawDocs();
     Iterator<Record> recordIterator = sortAndAggregateSegmentRecords(numSegmentRecords);
@@ -314,13 +314,14 @@ abstract class BaseSingleTreeBuilder implements SingleTreeBuilder {
     int numStarTreeRecords = _numDocs;
     LOGGER.info("Generated {} star-tree records from {} segment records", numStarTreeRecords, numSegmentRecords);
 
-    int numRecordsUnderStarNode = _numDocs - numStarTreeRecords;
     constructStarTree(_rootNode, 0, _numDocs);
+    int numRecordsUnderStarNode = _numDocs - numStarTreeRecords;
     LOGGER.info("Finish constructing star-tree, got {} tree nodes and {} records under star-node", _numNodes,
         numRecordsUnderStarNode);
 
     createAggregatedDocs(_rootNode);
-    LOGGER.info("Finish creating aggregated documents, got {} aggregated records", _numDocs - numRecordsUnderStarNode);
+    int numAggregatedRecords = _numDocs - numSegmentRecords - numRecordsUnderStarNode;
+    LOGGER.info("Finish creating aggregated documents, got {} aggregated records", numAggregatedRecords);
 
     createForwardIndexes();
     StarTreeBuilderUtils


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org