[fix](move-memtable) fix auto partition load issue caused by #42039 (#…

…42484) (#42486) backport #42484
apache · Oct 25, 2024 · 83b81c1 · 83b81c1
1 parent 859332c
commit 83b81c1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/be/src/vec/sink/load_stream_map_pool.cpp b/be/src/vec/sink/load_stream_map_pool.cpp
@@ -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;