diff --git a/presto-native-execution/presto_cpp/main/operators/ShuffleRead.cpp b/presto-native-execution/presto_cpp/main/operators/ShuffleRead.cpp index d644c7ce0ac5b..0167ac91d5355 100644 --- a/presto-native-execution/presto_cpp/main/operators/ShuffleRead.cpp +++ b/presto-native-execution/presto_cpp/main/operators/ShuffleRead.cpp @@ -97,7 +97,7 @@ RowVectorPtr ShuffleRead::getOutput() { (preferredOutputBatchBytes_ / estimatedRowSize_.value()), kInitialOutputRows); } - numOutputRows = std::min(numOutputRows, rows_.size() - nextRow_); + numOutputRows = std::min(numOutputRows, rows_.size() - nextRow_); // Create a view of the rows to deserialize from nextRow_ to nextRow_ + // numOutputRows.