Fix bug in intermidiated data writes stats collection

prestodb · May 31, 2019 · 7bd1426 · 7bd1426
1 parent f65d4d9
commit 7bd1426
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/presto-main/src/main/java/com/facebook/presto/execution/QueryStateMachine.java b/presto-main/src/main/java/com/facebook/presto/execution/QueryStateMachine.java
@@ -481,7 +481,7 @@ private QueryStats getQueryStats(Optional<StageInfo> rootStage)
                 }
 
                 if (plan.isMaterializedExchangeSource()) {
-                    writtenOutputPhysicalDataSize += stageStats.getPhysicalWrittenDataSize().toBytes();
+                    writtenIntermediatePhysicalDataSize += stageStats.getPhysicalWrittenDataSize().toBytes();
                 }
                 else {
                     writtenOutputPositions += stageInfo.getStageStats().getOperatorSummaries().stream()