diff --git a/presto-main/src/main/java/io/prestosql/server/protocol/Query.java b/presto-main/src/main/java/io/prestosql/server/protocol/Query.java index c72658d0007b..0cf2c9dac0d7 100644 --- a/presto-main/src/main/java/io/prestosql/server/protocol/Query.java +++ b/presto-main/src/main/java/io/prestosql/server/protocol/Query.java @@ -722,7 +722,7 @@ private static StatementStats toStatementStats(QueryInfo queryInfo) .setProcessedRows(queryStats.getRawInputPositions()) .setProcessedBytes(queryStats.getRawInputDataSize().toBytes()) .setPhysicalInputBytes(queryStats.getPhysicalInputDataSize().toBytes()) - .setPeakMemoryBytes(queryStats.getPeakUserMemoryReservation().toBytes()) + .setPeakMemoryBytes(queryStats.getPeakUserMemoryReservation().toBytes() + queryStats.getPeakNonRevocableMemoryReservation().toBytes()) .setSpilledBytes(queryStats.getSpilledDataSize().toBytes()) .setRootStage(toStageStats(outputStage)) .build();