From d627bdff4e4f760bb5d60cc118352d250cc03081 Mon Sep 17 00:00:00 2001 From: lilong Date: Tue, 3 Jan 2023 11:12:31 +0800 Subject: [PATCH] =?UTF-8?q?=E5=87=BD=E6=95=B0getlen=5Fstream=E4=B8=ADRESPO?= =?UTF-8?q?NSE=5FDATAROW=E5=88=86=E6=94=AF=E7=9B=B4=E6=8E=A5return?= =?UTF-8?q?=E5=90=8E=E7=BB=AD=E4=BB=A3=E7=A0=81=E6=97=A0=E6=95=88?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/common/backend/utils/sort/tuplesort.cpp | 6 ------ 1 file changed, 6 deletions(-) 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: