You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@arrow.apache.org by "marsupialtail (via GitHub)" <gi...@apache.org> on 2023/02/06 16:01:11 UTC

[GitHub] [arrow] marsupialtail opened a new issue, #34047: [C++][FlightRPC] Flight server problems with the streaming results in 11.0

marsupialtail opened a new issue, #34047:
URL: https://github.com/apache/arrow/issues/34047

   ### Describe the bug, including details regarding any error messages, version, and platform.
   
   Hi @lidavidm pyarrow 11.0 is breaking my arrow flight related code. I think you have a good sense what the problem is: /arrow/cpp/src/arrow/status.cc:137: DoAction result was not fully consumed: Cancelled: Flight cancelled call, with message: CANCELLED. Detail: Cancelled
   
   I seem to be fully consuming the DoAction results, e.g. here is my code:
   ```
   for result in self.flight_client.do_action(action):
         assert result.body.to_pybytes().decode("utf-8") == "True"
   ```
   
   Can you give some pointers on how to use Python to get results from do_action?
   
   ### Component(s)
   
   FlightRPC


-- 
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: issues-unsubscribe@arrow.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [arrow] lidavidm commented on issue #34047: [C++][FlightRPC] Flight server problems with the streaming results in 11.0

Posted by "lidavidm (via GitHub)" <gi...@apache.org>.
lidavidm commented on issue #34047:
URL: https://github.com/apache/arrow/issues/34047#issuecomment-1418171771

   It was basically a conflict between people who want this to be a proper iterator (in which case gRPC really wants you to drain the stream) and the original behavior which was to eagerly materialize the list.
   
   @marsupialtail do you want to leave this open? We could change it to not warn by default, at least.


-- 
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: github-unsubscribe@arrow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [arrow] lidavidm closed issue #34047: [C++][FlightRPC] Make warning about do_action stream less noisy

Posted by "lidavidm (via GitHub)" <gi...@apache.org>.
lidavidm closed issue #34047: [C++][FlightRPC] Make warning about do_action stream less noisy
URL: https://github.com/apache/arrow/issues/34047


-- 
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: issues-unsubscribe@arrow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [arrow] lidavidm commented on issue #34047: Flight server problems with the streaming results in 11.0

Posted by "lidavidm (via GitHub)" <gi...@apache.org>.
lidavidm commented on issue #34047:
URL: https://github.com/apache/arrow/issues/34047#issuecomment-1417728005

   This is just a warning, it shouldn't break anything.
   
   Otherwise: just try list(do_action(...))
   
   On Sun, Feb 5, 2023, at 00:27, Ziheng Wang wrote:
   > 
   > 
   > Describe the bug, including details regarding any error messages, version, and platform.
   > 
   > Hi @lidavidm <https://github.com/lidavidm> pyarrow 11.0 is breaking my arrow flight related code. I think you have a good sense what the problem is: /arrow/cpp/src/arrow/status.cc:137: DoAction result was not fully consumed: Cancelled: Flight cancelled call, with message: CANCELLED. Detail: Cancelled
   > 
   > I seem to be fully consuming the DoAction results, e.g. here is my code:
   > 
   > `for result in self.flight_client.do_action(action):
   >       assert result.body.to_pybytes().decode("utf-8") == "True"
   `
   > Can you give some pointers on how to use Python to get results from do_action?
   > 
   > Component(s)
   > 
   > FlightRPC
   > 
   > 
   > —
   > Reply to this email directly, view it on GitHub <https://github.com/apache/arrow/issues/34047>, or unsubscribe <https://github.com/notifications/unsubscribe-auth/AACQB34T6DA3PZECLJWKAUTWV424ZANCNFSM6AAAAAAURSMA64>.
   > You are receiving this because you were mentioned.Message ID: ***@***.***>
   > 


-- 
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: github-unsubscribe@arrow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [arrow] marsupialtail closed issue #34047: [C++][FlightRPC] Flight server problems with the streaming results in 11.0

Posted by "marsupialtail (via GitHub)" <gi...@apache.org>.
marsupialtail closed issue #34047: [C++][FlightRPC] Flight server problems with the streaming results in 11.0
URL: https://github.com/apache/arrow/issues/34047


-- 
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: issues-unsubscribe@arrow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [arrow] marsupialtail commented on issue #34047: Flight server problems with the streaming results in 11.0

Posted by "marsupialtail (via GitHub)" <gi...@apache.org>.
marsupialtail commented on issue #34047:
URL: https://github.com/apache/arrow/issues/34047#issuecomment-1418119092

   Can I disable this warning?


-- 
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: github-unsubscribe@arrow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [arrow] lidavidm commented on issue #34047: Flight server problems with the streaming results in 11.0

Posted by "lidavidm (via GitHub)" <gi...@apache.org>.
lidavidm commented on issue #34047:
URL: https://github.com/apache/arrow/issues/34047#issuecomment-1418144998

   Does `list(do_action(...))` work?
   
   I think a PR to remove the warning or change it to DEBUG level would be reasonable, it's probably a bit aggressive as-is.


-- 
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: github-unsubscribe@arrow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [arrow] marsupialtail commented on issue #34047: [C++][FlightRPC] Flight server problems with the streaming results in 11.0

Posted by "marsupialtail (via GitHub)" <gi...@apache.org>.
marsupialtail commented on issue #34047:
URL: https://github.com/apache/arrow/issues/34047#issuecomment-1418168959

   OK doing list() seems to work. But I still think this shouldn't be the default :-) 


-- 
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: github-unsubscribe@arrow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org