You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@arrow.apache.org by "David Li (Jira)" <ji...@apache.org> on 2022/07/01 15:58:00 UTC

[jira] [Closed] (ARROW-10460) [FlightRPC][Python] FlightRPC authentication mechanism changed and is undocumented, breaking current working code

     [ https://issues.apache.org/jira/browse/ARROW-10460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

David Li closed ARROW-10460.
----------------------------
    Fix Version/s:     (was: 1.0.1)
       Resolution: Won't Fix

I'm going to close this, since this appears to be gRPC behavior/not specifying a port was not meant to be supported.

> [FlightRPC][Python] FlightRPC authentication mechanism changed and is undocumented, breaking current working code
> -----------------------------------------------------------------------------------------------------------------
>
>                 Key: ARROW-10460
>                 URL: https://issues.apache.org/jira/browse/ARROW-10460
>             Project: Apache Arrow
>          Issue Type: Bug
>          Components: FlightRPC, Python
>    Affects Versions: 2.0.0
>         Environment: MacOS Catalina, python 3.7.4
>            Reporter: Carlo Mazzaferro
>            Priority: Major
>
> Authentication with FlightClient changed from version 1.0.1 to 2.0.0 and is undocumented. 
>  
> {{>>> from pyarrow import ___version___}}
> {{>> print(}}_{{_version}}_{{_)}}
> {{'1.0.1'}}
> {{>>> from handlers import ApiKeyClientAuthHandler  # custom handler}}}}
>  {{>>> from pyarrow.flight import FlightClient}}
>  {{>>> client = FlightClient(location="grpc+tcp://xxxxxxxxxx.com")}}
>  {{>>> client.authenticate(ApiKeyClientAuthHandler(api_key="xxxxx"))}}
> {{>>>}}
>  
> And the exact same code in 2.0.0 breaks
>  
> {{>>> from pyarrow import ___version___}}
> {{>> print(}}_{{_version}}_{{_)}}
> {{'2.0.0'}}
> {{>>> from handlers import ApiKeyClientAuthHandler  # custom handler}}}}
>  {{>>> from pyarrow.flight import FlightClient}}
>  {{>>> client = FlightClient(location="grpc+tcp://xxxxxxxxxx.com")}}
>  {{>>> client.authenticate(ApiKeyClientAuthHandler(api_key="xxxxx"))}}
> {{Traceback (most recent call last):}}
>  {{   File "scratch.py", line 15, in <module>}}
>  {{     client.authenticate(ApiKeyClientAuthHandler(api_key="xxxxxxxxxx"))}}
>  {{   File "pyarrow/_flight.pyx", line 1149, in pyarrow._flight.FlightClient.authenticate}}
>  {{   File "pyarrow/_flight.pyx", line 70, in pyarrow._flight.check_flight_status}}
>  {{pyarrow._flight.FlightUnavailableError: gRPC returned unavailable error, with message: failed to connect to all addresses}}
>  
> What happened?
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)