From e1e964488ad135cd7bf87fb6da610652a1ca94ea Mon Sep 17 00:00:00 2001
From: Kaijie Chen <ckj@apache.org>
Date: Wed, 15 May 2024 18:26:11 +0800
Subject: [PATCH] [fix](load) skip sending cancel rpc if VNodeChannel is not
 inited (#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 8e6cc8b48f7293..c684d251a3c35c 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);