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 197ee084239 [fix](load) skip sending cancel rpc if VNodeChannel is not
inited (#34897)
197ee084239 is described below
commit 197ee0842397c14d3b47b30baddeee8599c9a200
Author: Kaijie Chen <[email protected]>
AuthorDate: Wed May 15 18:26:11 2024 +0800
[fix](load) skip sending cancel rpc if VNodeChannel is not inited (#34897)
---
be/src/vec/sink/writer/vtablet_writer.cpp | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/be/src/vec/sink/writer/vtablet_writer.cpp
b/be/src/vec/sink/writer/vtablet_writer.cpp
index b858243fd91..e4065a66618 100644
--- a/be/src/vec/sink/writer/vtablet_writer.cpp
+++ b/be/src/vec/sink/writer/vtablet_writer.cpp
@@ -846,6 +846,10 @@ void VNodeChannel::cancel(const std::string& cancel_msg) {
// we don't need to wait last rpc finished, cause closure's release/reset
will join.
// But do we need brpc::StartCancel(call_id)?
_cancel_with_msg(cancel_msg);
+ // if not inited, _stub will be nullptr, skip sending cancel rpc
+ if (!_inited) {
+ return;
+ }
auto request = std::make_shared<PTabletWriterCancelRequest>();
request->set_allocated_id(&_parent->_load_id);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
