Skip to content

Commit

Permalink
Adjust OutputBuffer is full condition
Browse files Browse the repository at this point in the history
Assume OutputBuffer is full when the limit is reached but not yet exceeded.

This change does not impact real scenarious much, but quite convinient
when testing
  • Loading branch information
arhimondr committed Apr 16, 2024
1 parent 8676e8d commit ba6c959
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion velox/exec/OutputBuffer.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -474,7 +474,7 @@ bool OutputBuffer::enqueue(
VELOX_UNREACHABLE(PartitionedOutputNode::kindString(kind_));
}

if (bufferedBytes_ > maxSize_ && future) {
if (bufferedBytes_ >= maxSize_ && future) {
promises_.emplace_back("OutputBuffer::enqueue");
*future = promises_.back().getSemiFuture();
blocked = true;
Expand Down

0 comments on commit ba6c959

Please sign in to comment.