This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 2e8ec1850ff [bugfix](memleak) fix memleak in arrow input stream
(#51929) (#51992)
2e8ec1850ff is described below
commit 2e8ec1850ff094b79b2569dba250c6fdfc537652
Author: yiguolei <[email protected]>
AuthorDate: Fri Jun 20 14:07:45 2025 +0800
[bugfix](memleak) fix memleak in arrow input stream (#51929) (#51992)
---
be/src/vec/exec/format/arrow/arrow_pip_input_stream.cpp | 2 +-
be/src/vec/exec/format/arrow/arrow_pip_input_stream.h | 3 ++-
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/be/src/vec/exec/format/arrow/arrow_pip_input_stream.cpp
b/be/src/vec/exec/format/arrow/arrow_pip_input_stream.cpp
index 7bc32c7ab4b..1c4462befcc 100644
--- a/be/src/vec/exec/format/arrow/arrow_pip_input_stream.cpp
+++ b/be/src/vec/exec/format/arrow/arrow_pip_input_stream.cpp
@@ -32,7 +32,7 @@
namespace doris::vectorized {
ArrowPipInputStream::ArrowPipInputStream(io::FileReaderSPtr file_reader)
- : _file_reader(file_reader), _pos(0), _begin(true), _read_buf(new
uint8_t[4]) {
+ : _file_reader(file_reader), _pos(0), _begin(true) {
set_mode(arrow::io::FileMode::READ);
}
diff --git a/be/src/vec/exec/format/arrow/arrow_pip_input_stream.h
b/be/src/vec/exec/format/arrow/arrow_pip_input_stream.h
index fef4cf10903..61276ab1905 100644
--- a/be/src/vec/exec/format/arrow/arrow_pip_input_stream.h
+++ b/be/src/vec/exec/format/arrow/arrow_pip_input_stream.h
@@ -59,7 +59,8 @@ private:
io::FileReaderSPtr _file_reader;
int64_t _pos;
bool _begin;
- uint8_t* _read_buf;
+ // The read buf is very small, so use stack memory directly.
+ uint8_t _read_buf[4];
};
} // namespace vectorized
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
