This is an automated email from the ASF dual-hosted git repository.
liaoxin 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 95b5b0029f2 [debug](move-memtable) add debug logs for
skip_two_backends injection cases (#46826)
95b5b0029f2 is described below
commit 95b5b0029f2df1f71a283160d98641a1f850ef2e
Author: Kaijie Chen <chenkai...@selectdb.com>
AuthorDate: Sun Jan 12 22:35:09 2025 +0800
[debug](move-memtable) add debug logs for skip_two_backends injection cases
(#46826)
---
be/src/vec/sink/writer/vtablet_writer_v2.cpp | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git a/be/src/vec/sink/writer/vtablet_writer_v2.cpp
b/be/src/vec/sink/writer/vtablet_writer_v2.cpp
index f3ad6b1d5e3..c332e3bf2f2 100644
--- a/be/src/vec/sink/writer/vtablet_writer_v2.cpp
+++ b/be/src/vec/sink/writer/vtablet_writer_v2.cpp
@@ -392,11 +392,21 @@ Status VTabletWriterV2::_select_streams(int64_t
tablet_id, int64_t partition_id,
VLOG_DEBUG << fmt::format("_select_streams P{} I{} T{}", partition_id,
index_id, tablet_id);
_tablets_for_node[node_id].emplace(tablet_id, tablet);
auto stream = _load_stream_map->at(node_id)->select_one_stream();
+ DBUG_EXECUTE_IF("VTabletWriterV2._open_streams.skip_two_backends", {
+ LOG(INFO) << "[skip_two_backends](detail) tablet_id=" << tablet_id
+ << ", node_id=" << node_id
+ << ", stream_ok=" << (stream == nullptr ? "no" : "yes");
+ });
if (stream == nullptr) {
continue;
}
streams.emplace_back(std::move(stream));
}
+ DBUG_EXECUTE_IF("VTabletWriterV2._open_streams.skip_two_backends", {
+ LOG(INFO) << "[skip_two_backends](summary) tablet_id=" << tablet_id
+ << ", num_streams=" << streams.size()
+ << ", num_nodes=" << location->node_ids.size();
+ });
if (streams.size() <= location->node_ids.size() / 2) {
return Status::InternalError("not enough streams {}/{}",
streams.size(),
location->node_ids.size());
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
