Skip to content

Commit 6cbd3bf

Browse files
committed
fix quorum success invalid in move-memtable-on-sink load path
1 parent d95d647 commit 6cbd3bf

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

be/src/vec/sink/writer/vtablet_writer_v2.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -104,11 +104,11 @@ Status VTabletWriterV2::_incremental_open_streams(
104104
tablet.set_tablet_id(tablet_id);
105105
new_backends.insert(node);
106106
_tablets_for_node[node].emplace(tablet_id, tablet);
107+
_tablets_by_node[node].emplace(tablet_id);
107108
if (known_indexes.contains(index.index_id)) [[likely]] {
108109
continue;
109110
}
110111
_indexes_from_node[node].emplace_back(tablet);
111-
_tablets_by_node[node].emplace(tablet_id);
112112
known_indexes.insert(index.index_id);
113113
VLOG_DEBUG << "incremental open stream (" << partition->id << ", " << tablet_id
114114
<< ")";
@@ -347,11 +347,11 @@ Status VTabletWriterV2::_build_tablet_node_mapping() {
347347
// ignore fake tablet for auto partition
348348
continue;
349349
}
350+
_tablets_by_node[node].emplace(tablet_id);
350351
if (known_indexes.contains(index.index_id)) [[likely]] {
351352
continue;
352353
}
353354
_indexes_from_node[node].emplace_back(tablet);
354-
_tablets_by_node[node].emplace(tablet_id);
355355
known_indexes.insert(index.index_id);
356356
}
357357
_build_tablet_replica_info(tablet_id, partition);

0 commit comments

Comments
 (0)