This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 13e6e8af45f [fix](load) skip sending cancel rpc if VNodeChannel is not
inited (#34897) (#37577)
13e6e8af45f is described below
commit 13e6e8af45fe03b122021b088d358f49c0a195f2
Author: Kaijie Chen <c...@apache.org>
AuthorDate: Wed Jul 10 14:04:46 2024 +0800
[fix](load) skip sending cancel rpc if VNodeChannel is not inited (#34897)
(#37577)
cherry-pick #34897
---
be/src/vec/sink/vtablet_sink.cpp | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/be/src/vec/sink/vtablet_sink.cpp b/be/src/vec/sink/vtablet_sink.cpp
index 8e6cc8b48f7..c684d251a3c 100644
--- a/be/src/vec/sink/vtablet_sink.cpp
+++ b/be/src/vec/sink/vtablet_sink.cpp
@@ -834,6 +834,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 (_stub == nullptr) {
+ return;
+ }
PTabletWriterCancelRequest request;
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
