revert _tablets_for_node emplace in select streams

kaijchen · Sep 6, 2024 · 6bef4d8 · 6bef4d8
1 parent 688086a
commit 6bef4d8
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/be/src/vec/sink/writer/vtablet_writer_v2.cpp b/be/src/vec/sink/writer/vtablet_writer_v2.cpp
@@ -379,8 +379,10 @@ Status VTabletWriterV2::_select_streams(int64_t tablet_id, int64_t partition_id,
  tablet.set_index_id(index_id);
  tablet.set_tablet_id(tablet_id);
  VLOG_DEBUG << fmt::format("_select_streams P{} I{} T{}", partition_id, index_id, tablet_id);
- CHECK(_tablets_for_node[node_id].contains(tablet_id));
- //_tablets_for_node[node_id].emplace(tablet_id, tablet); // TODO
+ LOG(INFO) << "select_strams, load_id=" << print_id(_load_id) << ", tablet_id=" << tablet_id
+ << ", dst_id=" << node_id << ", _tablets_for_node.contains="
+ << _tablets_for_node[node_id].contains(tablet_id);
+ _tablets_for_node[node_id].emplace(tablet_id, tablet);
  streams.emplace_back(_load_stream_map->at(node_id)->at(_stream_index));
  RETURN_IF_ERROR(streams[0]->wait_for_schema(partition_id, index_id, tablet_id));
  }