aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/backend/utils/sort/tuplesort.c5
1 files changed, 3 insertions, 2 deletions
diff --git a/src/backend/utils/sort/tuplesort.c b/src/backend/utils/sort/tuplesort.c
index 0c5c574cbd3..9e93908c657 100644
--- a/src/backend/utils/sort/tuplesort.c
+++ b/src/backend/utils/sort/tuplesort.c
@@ -2923,7 +2923,7 @@ mergeruns(Tuplesortstate *state)
* Rewind all the output tapes, and make them inputs for the next
* pass.
*/
- if (state->nInputRuns == 0 && !WORKER(state))
+ if (state->nInputRuns == 0)
{
int64 input_buffer_size;
@@ -2975,7 +2975,8 @@ mergeruns(Tuplesortstate *state)
* sorted tape, we can stop at this point and do the final merge
* on-the-fly.
*/
- if (!state->randomAccess && state->nInputRuns <= state->nInputTapes)
+ if (!state->randomAccess && state->nInputRuns <= state->nInputTapes
+ && !WORKER(state))
{
/* Tell logtape.c we won't be writing anymore */
LogicalTapeSetForgetFreeSpace(state->tapeset);