This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch dev-1.1.2
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/dev-1.1.2 by this push:
new 4a2b4d05b3 [fix][Vectorized] Fix nullptr deref in data sink (#11473)
4a2b4d05b3 is described below
commit 4a2b4d05b31b56d4388dd170314708111a82d3bd
Author: Amos Bird <amosb...@gmail.com>
AuthorDate: Mon Aug 22 11:44:55 2022 +0800
[fix][Vectorized] Fix nullptr deref in data sink (#11473)
brpc cache may return nullptr.
---
be/src/vec/sink/vdata_stream_sender.cpp | 7 +++++++
1 file changed, 7 insertions(+)
diff --git a/be/src/vec/sink/vdata_stream_sender.cpp
b/be/src/vec/sink/vdata_stream_sender.cpp
index 0f1cf57c7f..416e96954e 100644
--- a/be/src/vec/sink/vdata_stream_sender.cpp
+++ b/be/src/vec/sink/vdata_stream_sender.cpp
@@ -68,6 +68,13 @@ Status VDataStreamSender::Channel::init(RuntimeState* state)
{
_brpc_stub =
state->exec_env()->brpc_internal_client_cache()->get_client(_brpc_dest_addr);
}
+ if (!_brpc_stub) {
+ std::string msg = fmt::format("Get rpc stub failed, dest_addr={}:{}",
+ _brpc_dest_addr.hostname,
_brpc_dest_addr.port);
+ LOG(WARNING) << msg;
+ return Status::InternalError(msg);
+ }
+
// In bucket shuffle join will set fragment_instance_id (-1, -1)
// to build a camouflaged empty channel. the ip and port is '0.0.0.0:0"
// so the empty channel not need call function close_internal()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
