From 57630578b98b0e5c8467b38d8f481900b481958c Mon Sep 17 00:00:00 2001
From: Kaijie Chen <ckj@apache.org>
Date: Fri, 29 Mar 2024 10:16:05 +0800
Subject: [PATCH] [fix](load) skip cancel rpc if stub is not initialized

---
 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 a4e539b4bf6335..337a5181ac6da5 100644
--- a/be/src/vec/sink/vtablet_sink.cpp
+++ b/be/src/vec/sink/vtablet_sink.cpp
@@ -852,6 +852,10 @@ void VNodeChannel::cancel(const std::string& cancel_msg) {
     // But do we need brpc::StartCancel(call_id)?
     _cancel_with_msg(cancel_msg);
 
+    if (_stub == nullptr) {
+        return;
+    }
+
     PTabletWriterCancelRequest request;
     request.set_allocated_id(&_parent->_load_id);
     request.set_index_id(_index_channel->_index_id);