This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new f55fba7ceaf branch-2.1: [debug](move-memtable) add debug logs for
skip_two_backends injection cases #46826 (#46945)
f55fba7ceaf is described below
commit f55fba7ceafab7a381d4633ed39544e3a8d9fdd4
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Feb 12 09:58:57 2025 +0800
branch-2.1: [debug](move-memtable) add debug logs for skip_two_backends
injection cases #46826 (#46945)
Cherry-picked from #46826
Co-authored-by: Kaijie Chen <[email protected]>
---
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 c7cb4885bcd..7ba9f655b1b 100644
--- a/be/src/vec/sink/writer/vtablet_writer_v2.cpp
+++ b/be/src/vec/sink/writer/vtablet_writer_v2.cpp
@@ -390,11 +390,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: [email protected]
For additional commands, e-mail: [email protected]
