don't reuse cache

cockroachdb · Nov 12, 2021 · c17884a · c17884a
1 parent d2debd7
commit c17884a
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/pkg/sql/colcontainer/diskqueue.go b/pkg/sql/colcontainer/diskqueue.go
@@ -587,11 +587,9 @@ func (d *diskQueue) Enqueue(ctx context.Context, b coldata.Batch) error {
 		d.serializer = nil
 		d.done = true
 		if d.cfg.CacheMode == DiskQueueCacheModeDefault {
-			// From this point on only Dequeues are allowed. Reuse the write
-			// side of the cache for reads.
-			d.writer.buffer.Reset()
-			d.scratchDecompressedReadBytes = d.writer.buffer.Bytes()
+			d.scratchDecompressedReadBytes = nil
 			d.writer.buffer = bytes.Buffer{}
+			d.writer.scratch.compressedBuf = nil
 		}
 		return nil
 	}