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
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 0a3874f203f [fix](move-memtable) close stream when cancel load stream
stub (#38912) (#39039)
0a3874f203f is described below
commit 0a3874f203f2f279dc1eda0348c2d9d8074b5a5b
Author: Kaijie Chen <[email protected]>
AuthorDate: Wed Aug 7 23:24:00 2024 +0800
[fix](move-memtable) close stream when cancel load stream stub (#38912)
(#39039)
backport #38912
---
be/src/vec/sink/load_stream_stub.cpp | 3 +++
1 file changed, 3 insertions(+)
diff --git a/be/src/vec/sink/load_stream_stub.cpp
b/be/src/vec/sink/load_stream_stub.cpp
index 93f3fd87a85..dc34b13e0ac 100644
--- a/be/src/vec/sink/load_stream_stub.cpp
+++ b/be/src/vec/sink/load_stream_stub.cpp
@@ -338,6 +338,9 @@ Status LoadStreamStub::close_wait(RuntimeState* state,
int64_t timeout_ms) {
void LoadStreamStub::cancel(Status reason) {
LOG(WARNING) << *this << " is cancelled because of " << reason;
+ if (_is_init.load()) {
+ brpc::StreamClose(_stream_id);
+ }
{
std::lock_guard<bthread::Mutex> lock(_cancel_mutex);
_cancel_reason = reason;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
