diff --git a/dbms/src/DataStreams/MergingAggregatedBlockInputStream.cpp b/dbms/src/DataStreams/MergingAggregatedBlockInputStream.cpp index d833ed6209b..9db77eced59 100644 --- a/dbms/src/DataStreams/MergingAggregatedBlockInputStream.cpp +++ b/dbms/src/DataStreams/MergingAggregatedBlockInputStream.cpp @@ -22,7 +22,7 @@ Block MergingAggregatedBlockInputStream::readImpl() if (isCancelled() || it == blocks.end()) return res; - res = *it; + res = std::move(*it); ++it; return res; diff --git a/dbms/src/Interpreters/Aggregator.cpp b/dbms/src/Interpreters/Aggregator.cpp index a5087345fe4..eb2c67e98fc 100644 --- a/dbms/src/Interpreters/Aggregator.cpp +++ b/dbms/src/Interpreters/Aggregator.cpp @@ -1071,7 +1071,7 @@ BlocksList Aggregator::convertToBlocks(AggregatedDataVariants & data_variants, b double elapsed_seconds = watch.elapsedSeconds(); LOG_TRACE(log, std::fixed << std::setprecision(3) - << "Converted aggregated data to block. " + << "Converted aggregated data to blocks. " << rows << " rows, " << bytes / 1048576.0 << " MiB" << " in " << elapsed_seconds << " sec." << " (" << rows / elapsed_seconds << " rows/sec., " << bytes / elapsed_seconds / 1048576.0 << " MiB/sec.)");