You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by ko...@apache.org on 2022/04/11 20:43:40 UTC

[arrow] branch master updated: ARROW-16162: [C++][FlightRPC] Fix Flight build on Ubuntu 18.04

This is an automated email from the ASF dual-hosted git repository.

kou pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow.git


The following commit(s) were added to refs/heads/master by this push:
     new 71ba864257 ARROW-16162: [C++][FlightRPC] Fix Flight build on Ubuntu 18.04
71ba864257 is described below

commit 71ba86425765478e5bc7a9db3eacf85bb8e21515
Author: David Li <li...@gmail.com>
AuthorDate: Tue Apr 12 05:43:28 2022 +0900

    ARROW-16162: [C++][FlightRPC] Fix Flight build on Ubuntu 18.04
    
    Closes #12856 from lidavidm/arrow-16162
    
    Authored-by: David Li <li...@gmail.com>
    Signed-off-by: Sutou Kouhei <ko...@clear-code.com>
---
 cpp/src/arrow/flight/client.cc | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/cpp/src/arrow/flight/client.cc b/cpp/src/arrow/flight/client.cc
index daec8e3a9b..a5d6cd7c37 100644
--- a/cpp/src/arrow/flight/client.cc
+++ b/cpp/src/arrow/flight/client.cc
@@ -610,11 +610,13 @@ arrow::Result<std::unique_ptr<FlightStreamReader>> FlightClient::DoGet(
   RETURN_NOT_OK(CheckOpen());
   std::unique_ptr<internal::ClientDataStream> remote_stream;
   RETURN_NOT_OK(transport_->DoGet(options, ticket, &remote_stream));
-  auto stream_reader = arrow::internal::make_unique<ClientStreamReader>(
-      std::move(remote_stream), options.read_options, options.stop_token,
-      options.memory_manager);
+  std::unique_ptr<FlightStreamReader> stream_reader =
+      arrow::internal::make_unique<ClientStreamReader>(
+          std::move(remote_stream), options.read_options, options.stop_token,
+          options.memory_manager);
   // Eagerly read the schema
-  RETURN_NOT_OK(stream_reader->EnsureDataStarted());
+  RETURN_NOT_OK(
+      static_cast<ClientStreamReader*>(stream_reader.get())->EnsureDataStarted());
   return stream_reader;
 }