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
commit 849eeb39e9c25645498966c681c7d2c115db8262
Author: Kaijie Chen <c...@apache.org>
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 c2a029e7870..3fb17850eff 100644
--- a/be/src/vec/sink/writer/vtablet_writer.cpp
+++ b/be/src/vec/sink/writer/vtablet_writer.cpp
@@ -841,6 +841,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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
