[doris] branch branch-2.0 updated: branch-2.0](fix) compile error when compiler opens -Werror and -Wunused-result (#24319)

[kxiao]

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: 任宇华 <79885238+ry...@users.noreply.github.com>
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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org