database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[bugfix](memleak) fix memleak in arrow input stream (#51929) (#51992)

Browse Source
This commit is contained in:
yiguolei
2025-06-20 14:07:45 +08:00
committed by GitHub
parent 614c7f8579
commit 2e8ec1850f
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
be/src/vec/exec/format/arrow/arrow_pip_input_stream.cpp
View File

@ -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);
}

3
be/src/vec/exec/format/arrow/arrow_pip_input_stream.h
View File

@ -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