From ce4d549eca5bdcbeaaf4a5ef0235385243b5276c Mon Sep 17 00:00:00 2001
From: Kaijie Chen <ckj@apache.org>
Date: Wed, 15 May 2024 13:42:49 +0800
Subject: [PATCH] [fix](load) skip sending cancel rpc if VNodeChannel is not
 inited

---
 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 3d97f71d7df772..4d0cdc5c089e39 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);