Switch to estimateCompactSize when reporting outputBytes statistics

kewang1024 · Apr 9, 2024 · cfee0c8 · cfee0c8
1 parent 8db0b71
commit cfee0c8
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/velox/exec/Driver.cpp b/velox/exec/Driver.cpp
@@ -590,7 +590,7 @@ StopReason Driver::runInternal(
                 if (ctx_->queryConfig().validateOutputFromOperators()) {
                   validateOperatorResult(intermediateResult, *op);
                 }
-                resultBytes = intermediateResult->estimateFlatSize();
+                resultBytes = intermediateResult->estimateCompactSize();
                 {
                   auto lockedStats = op->stats().wlock();
                   lockedStats->addOutputVector(
@@ -699,7 +699,7 @@ StopReason Driver::runInternal(
               {
                 auto lockedStats = op->stats().wlock();
                 lockedStats->addOutputVector(
-                    result->estimateFlatSize(), result->size());
+                    result->estimateCompactSize(), result->size());
               }
 
               // This code path is used only in single-threaded execution.