Re: Arrow Flight Connection Handling
On 2021/09/13 14:18:21, "David Li" wrote: > Hello, > > For this, you will have to depend on the fact that Flight is currently > implemented with gRPC. This means: > 1. Take a dependency on flight-grpc, > 2. Configure a plain gRPC server following the grpc-java docs, > 3. Add the Flight service to the gRPC server via FlightGrpcUtils[1] > Then you can get the peer address from grpc-java by installing a gRPC > interceptor that reads the address and places it in the gRPC context. From > within the FlightProducer, you can then access the gRPC context. This is > described briefly at [2] and you can see a short (incomplete) code snippet at > [3]. > > Maybe Flight could pull this info for you, this was done for C++/Python at > [4] - though it would be an opaque/transport-dependent string. > > [1]: > https://arrow.apache.org/docs/java/reference/org/apache/arrow/flight/FlightGrpcUtils.html#createFlightService-org.apache.arrow.memory.BufferAllocator-org.apache.arrow.flight.FlightProducer-org.apache.arrow.flight.auth.ServerAuthHandler-java.util.concurrent.ExecutorService- > [2]: https://stackoverflow.com/a/52633506 > [3]: https://github.com/grpc/grpc-java/issues/5489 > [4]: https://issues.apache.org/jira/browse/ARROW-9175 > > Best, > David > I have done most of those steps, but i missed the way to access the ip from the FlightProducer RPCs context, Context is empty, I need to attach the ip with each call context
Arrow Flight Connection Handling
in Java Arrow Flight protocol, I would like to access the client address and port whenever a FlightClient connects to FlightServer. is there a way to do so? Thanks in advance
Arrow Flight Connection Handling
in java Arrow Flight, I would like to access the client host and port whenever a FlightClient get connected to FlightServer is there a way to do so? Thanks in Advance
Re: HTTP traffic of Arrow Flight
Yes, I got it, I have to do decode as and choose HTTP2 protocol Thanks a lot On 2021/09/07 17:06:10, "David Li" wrote: > Yes and to be extra clear, Flight currently only supports gRPC, and hence > HTTP/2 (barring a few hypothetical configurations), it may also be that you > need to explicitly tell WireShark the protocol in use. > > -David > > On Tue, Sep 7, 2021, at 13:03, Nate Bauernfeind wrote: > > HTTP (and HTTP/2) traffic is sent over TCP. You might need to be more > > specific, or possibly do some more research on your end > > > > Which arrow flight client are you using in your test? Java? C++? Which > > version? Can you provide a simple gRPC server/client example that shows up > > in WireShark as you expect it? > > > > Nate > > > > On Tue, Sep 7, 2021 at 10:40 AM Mohamed Abdelhakem < > > mohamed.abdelha...@incorta.com> wrote: > > > > > When I built a simple FlightServer and FlightClient, I noticed that the > > > traffic captured by WireShark is TCP, not HTTP/2 > > > MY question is how to configure Arrow Flight to use HTTP/2 protocol > > > traffic > > > > > > > > > -- > > >
Re: HTTP traffic of Arrow Flight
I am using Java Flight Client using Arrow Flight gRPC version 5.0 On 2021/09/07 17:03:42, Nate Bauernfeind wrote: > HTTP (and HTTP/2) traffic is sent over TCP. You might need to be more > specific, or possibly do some more research on your end > > Which arrow flight client are you using in your test? Java? C++? Which > version? Can you provide a simple gRPC server/client example that shows up > in WireShark as you expect it? > > Nate > > On Tue, Sep 7, 2021 at 10:40 AM Mohamed Abdelhakem < > mohamed.abdelha...@incorta.com> wrote: > > > When I built a simple FlightServer and FlightClient, I noticed that the > > traffic captured by WireShark is TCP, not HTTP/2 > > MY question is how to configure Arrow Flight to use HTTP/2 protocol traffic > > > > > -- >
HTTP traffic of Arrow Flight
When I built a simple FlightServer and FlightClient, I noticed that the traffic captured by WireShark is TCP, not HTTP/2 MY question is how to configure Arrow Flight to use HTTP/2 protocol traffic
