Skip to content

Commit

Permalink
[fix](move-memtable) fix auto partition load issue caused by #42039 (#…
Browse files Browse the repository at this point in the history
…42484)

Fix incremental streams is not closed, a bug introduced in #42039
  • Loading branch information
kaijchen authored Oct 25, 2024
1 parent ddc91cc commit b9a287e
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion be/src/vec/sink/load_stream_map_pool.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -107,7 +107,7 @@ bool LoadStreamMap::release() {

void LoadStreamMap::close_load(bool incremental) {
for (auto& [dst_id, streams] : _streams_for_node) {
if (streams->is_incremental()) {
if (streams->is_incremental() != incremental) {
continue;
}
std::vector<PTabletID> tablets_to_commit;
Expand Down

0 comments on commit b9a287e

Please sign in to comment.