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;
}