Resume buffer_size_ to buffer_->size() call

mapleFU · Oct 24, 2024 · aecf05e · aecf05e
1 parent 0a111dc
commit aecf05e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cpp/src/arrow/io/buffered.cc b/cpp/src/arrow/io/buffered.cc
@@ -326,7 +326,7 @@ class BufferedInputStream::Impl : public BufferedBase {
     }
 
     // Increase the buffer size if needed.
-    if (nbytes > buffer_size_ - buffer_pos_) {
+    if (nbytes > buffer_->size() - buffer_pos_) {
       RETURN_NOT_OK(SetBufferSize(nbytes + buffer_pos_));
       DCHECK(buffer_->size() - buffer_pos_ >= nbytes);
     }