hu6360567 commented on issue #36749:
URL: https://github.com/apache/arrow/issues/36749#issuecomment-1640148071
It seems type of writer/reader from client/server are not all the same. The
client has an option to tell server `done_writing` before the writer from
client closed.
If on the client side, writer always closes after reader. For example, the
client is echoing from the server
```python
client = pa.flight.FlightClient(location="grpc://127.0.0.1:12345")
writer, reader =
client.do_exchange(pa.flight.FlightDescriptor.for_command(b""))
rb_reader = reader.to_reader()
writer.begin(rb_reader.schema)
for rb in rb_reader:
writer.write(rb) # or something, compute with rb
writer.done_writing()
writer.close()
```
Then it will **always** stuck on the line of `for rb in rb_reader` forever .
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
