This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 3a7ef501343 branch-2.0](fix) compile error when compiler opens -Werror
and -Wunused-result (#24319)
3a7ef501343 is described below
commit 3a7ef501343ea552d8838eef37ef6fa9181c6392
Author: 任宇华 <[email protected]>
AuthorDate: Mon Sep 18 20:35:17 2023 +0800
branch-2.0](fix) compile error when compiler opens -Werror and
-Wunused-result (#24319)
---
be/src/pipeline/exec/exchange_sink_buffer.cpp | 4 ++--
be/src/vec/sink/vdata_stream_sender.cpp | 2 +-
be/src/vec/sink/vtablet_sink.cpp | 8 ++++----
3 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/be/src/pipeline/exec/exchange_sink_buffer.cpp
b/be/src/pipeline/exec/exchange_sink_buffer.cpp
index bf43c3b860c..9407e24dbcd 100644
--- a/be/src/pipeline/exec/exchange_sink_buffer.cpp
+++ b/be/src/pipeline/exec/exchange_sink_buffer.cpp
@@ -229,7 +229,7 @@ Status ExchangeSinkBuffer::_send_rpc(InstanceLoId id) {
}
}
if (request.block) {
- brpc_request->release_block();
+ static_cast<void>(brpc_request->release_block());
}
q.pop();
} else if (!broadcast_q.empty()) {
@@ -282,7 +282,7 @@ Status ExchangeSinkBuffer::_send_rpc(InstanceLoId id) {
}
}
if (request.block_holder->get_block()) {
- brpc_request->release_block();
+ static_cast<void>(brpc_request->release_block());
}
broadcast_q.pop();
} else {
diff --git a/be/src/vec/sink/vdata_stream_sender.cpp
b/be/src/vec/sink/vdata_stream_sender.cpp
index 43c7919671a..ad473fcd775 100644
--- a/be/src/vec/sink/vdata_stream_sender.cpp
+++ b/be/src/vec/sink/vdata_stream_sender.cpp
@@ -192,7 +192,7 @@ Status Channel::send_block(PBlock* block, bool eos) {
}
if (block != nullptr) {
- _brpc_request.release_block();
+ static_cast<void>(_brpc_request.release_block());
}
return Status::OK();
}
diff --git a/be/src/vec/sink/vtablet_sink.cpp b/be/src/vec/sink/vtablet_sink.cpp
index 25013a831b5..a112a1f3f21 100644
--- a/be/src/vec/sink/vtablet_sink.cpp
+++ b/be/src/vec/sink/vtablet_sink.cpp
@@ -277,7 +277,7 @@ VNodeChannel::~VNodeChannel() {
if (_open_closure != nullptr) {
delete _open_closure;
}
- _cur_add_block_request.release_id();
+ static_cast<void>(_cur_add_block_request.release_id());
}
void VNodeChannel::clear_all_blocks() {
@@ -370,8 +370,8 @@ void VNodeChannel::open() {
}
_stub->tablet_writer_open(&_open_closure->cntl, &request,
&_open_closure->result,
_open_closure);
- request.release_id();
- request.release_schema();
+ static_cast<void>(request.release_id());
+ static_cast<void>(request.release_schema());
}
Status VNodeChannel::open_wait() {
@@ -855,7 +855,7 @@ void VNodeChannel::cancel(const std::string& cancel_msg) {
closure->cntl.ignore_eovercrowded();
}
_stub->tablet_writer_cancel(&closure->cntl, &request, &closure->result,
closure);
- request.release_id();
+ static_cast<void>(request.release_id());
}
bool VNodeChannel::is_send_data_rpc_done() const {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
