This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 dcb42e87175 [fix](partition) Add more log for single replica load when
partition id eq 0 (#28707)
dcb42e87175 is described below
commit dcb42e87175003155ed9bf40b1fc3d7473a9552f
Author: deardeng <[email protected]>
AuthorDate: Sat Jan 13 09:29:15 2024 +0800
[fix](partition) Add more log for single replica load when partition id eq
0 (#28707)
---
be/src/olap/delta_writer.cpp | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
diff --git a/be/src/olap/delta_writer.cpp b/be/src/olap/delta_writer.cpp
index ee6eb357e4c..bc1152fcd1f 100644
--- a/be/src/olap/delta_writer.cpp
+++ b/be/src/olap/delta_writer.cpp
@@ -249,7 +249,15 @@ void
DeltaWriter::_request_slave_tablet_pull_rowset(PNodeInfo node_info) {
}
auto request = std::make_shared<PTabletWriteSlaveRequest>();
- *(request->mutable_rowset_meta()) =
cur_rowset->rowset_meta()->get_rowset_pb();
+ auto request_mutable_rs_meta = request->mutable_rowset_meta();
+ *request_mutable_rs_meta = cur_rowset->rowset_meta()->get_rowset_pb();
+ if (request_mutable_rs_meta != nullptr &&
request_mutable_rs_meta->has_partition_id() &&
+ request_mutable_rs_meta->partition_id() == 0) {
+ // TODO(dx): remove log after fix partition id eq 0 bug
+ request_mutable_rs_meta->set_partition_id(_req.partition_id);
+ LOG(WARNING) << "cant get partition id from local rs pb, get from
_req, partition_id="
+ << _req.partition_id;
+ }
request->set_host(BackendOptions::get_localhost());
request->set_http_port(config::webserver_port);
string tablet_path = _rowset_builder->tablet()->tablet_path();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
