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

[fix](move-memtable) fix streams for node memory leak in sink v2 (#29146)

Browse Source
This commit is contained in:
Kaijie Chen
2023-12-27 21:48:32 +08:00
committed by GitHub
parent d96278ab21
commit 0cc4ee52bf
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
be/src/vec/sink/writer/vtablet_writer_v2.cpp
View File

@ -502,6 +502,7 @@ Status VTabletWriterV2::close(Status exec_status) {
for (const auto& [_, streams] : _streams_for_node) {
streams->release();
}
_streams_for_node.clear();
});
{
@ -541,7 +542,6 @@ Status VTabletWriterV2::close(Status exec_status) {
_state->tablet_commit_infos().insert(_state->tablet_commit_infos().end(),
std::make_move_iterator(tablet_commit_infos.begin()),
std::make_move_iterator(tablet_commit_infos.end()));
_streams_for_node.clear();
// _number_input_rows don't contain num_rows_load_filtered and num_rows_load_unselected in scan node
int64_t num_rows_load_total = _number_input_rows + _state->num_rows_load_filtered() +