diff --git a/src/common/backend/utils/sort/tuplesort.cpp b/src/common/backend/utils/sort/tuplesort.cpp
index 90451aed8..9e6c6102a 100644
--- a/src/common/backend/utils/sort/tuplesort.cpp
+++ b/src/common/backend/utils/sort/tuplesort.cpp
@@ -4295,12 +4295,6 @@ static unsigned int getlen_stream(Tuplesortstate* state, int tapenum, bool eofOK
             } break;
             case RESPONSE_DATAROW: {
                 return node->buf.len;
-                /* If we have message in the buffer, consume it */
-                if (node->buf.len != 0) {
-                    AssembleDataRow(node);
-                    node->need_fresh_data = false;
-                    return true;
-                }
             } break;
 
             default: