This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 0cc4ee52bf3 [fix](move-memtable) fix streams for node memory leak in
sink v2 (#29146)
0cc4ee52bf3 is described below
commit 0cc4ee52bf3dcc8cc6b928f14be8a4e3855623f5
Author: Kaijie Chen <[email protected]>
AuthorDate: Wed Dec 27 21:48:32 2023 +0800
[fix](move-memtable) fix streams for node memory leak in sink v2 (#29146)
---
be/src/vec/sink/writer/vtablet_writer_v2.cpp | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/be/src/vec/sink/writer/vtablet_writer_v2.cpp
b/be/src/vec/sink/writer/vtablet_writer_v2.cpp
index ae753c8714a..f413c00dc0c 100644
--- a/be/src/vec/sink/writer/vtablet_writer_v2.cpp
+++ b/be/src/vec/sink/writer/vtablet_writer_v2.cpp
@@ -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() +
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
