diff --git a/dbms/src/Processors/Merges/AggregatingSortedTransform.cpp b/dbms/src/Processors/Merges/AggregatingSortedTransform.cpp
index 3de4e7773f0..b3a1be9f253 100644
--- a/dbms/src/Processors/Merges/AggregatingSortedTransform.cpp
+++ b/dbms/src/Processors/Merges/AggregatingSortedTransform.cpp
@@ -117,7 +117,7 @@ void AggregatingSortedTransform::updateCursor(Chunk chunk, size_t source_num)
     {
         /// Extend lifetime of last chunk.
         last_chunk = std::move(source_chunk);
-        last_chunk_sort_columns = std::move(cursors[source_num].all_columns);
+        last_chunk_sort_columns = std::move(cursors[source_num].sort_columns);
 
         source_chunk = std::move(chunk);
         cursors[source_num].reset(source_chunk.getColumns(), {});
diff --git a/dbms/src/Processors/Merges/SummingSortedTransform.cpp b/dbms/src/Processors/Merges/SummingSortedTransform.cpp
index af97999a4b9..f34a3b479d7 100644
--- a/dbms/src/Processors/Merges/SummingSortedTransform.cpp
+++ b/dbms/src/Processors/Merges/SummingSortedTransform.cpp
@@ -411,7 +411,7 @@ void SummingSortedTransform::updateCursor(Chunk chunk, size_t source_num)
     {
         /// Extend lifetime of last chunk.
         last_chunk = std::move(source_chunk);
-        last_chunk_sort_columns = std::move(cursors[source_num].all_columns);
+        last_chunk_sort_columns = std::move(cursors[source_num].sort_columns);
 
         source_chunk = std::move(chunk);
         cursors[source_num].reset(source_chunk.getColumns(), {});