mirror of
https://github.com/apache/arrow.git
synced 2026-10-28 16:47:19 +08:00
Treat null FlightDataStream as error
This commit is contained in:
1 parent
1d0b3697ef
commit
35c62f6942
1 file changed
+4
@@ -180,6 +180,10 @@ class FlightServiceImpl : public FlightService::Service {
|
||||
std::unique_ptr<FlightDataStream> data_stream;
|
||||
GRPC_RETURN_NOT_OK(server_->DoGet(ticket, &data_stream));
|
||||
|
||||
if (data_stream == nullptr) {
|
||||
return grpc::Status(grpc::StatusCode::NOT_FOUND, "No data in this flight");
|
||||
}
|
||||
|
||||
// Write the schema as the first message in the stream
|
||||
FlightPayload schema_payload;
|
||||
MemoryPool* pool = default_memory_pool();
|
||||
|
||||
Reference in new issue
Block a user