How to decode the body of HTTP request from beeline client in "transportMode=http"? the body seems encoded by thrift protocol.

[rubberliu]

I want to decode the body of HTTP request from beeline client in "transportMode=http", just like:
beeline -u "jdbc:hive2://xxx.xxx:<port>/;transportMode=http;httpPath=cliservice"

since the body has been encoded by thrift protocol, I use code:

ByteBuf content = request.content().copy();
         byte[] data = new byte[content.readableBytes()];
         content.readBytes(data);
         logger.info("AuthenticationHandler extractUserPass: " +
         request.content().toString(CharsetUtil.UTF_8));
         TDeserializer deserializer = new TDeserializer(new TBinaryProtocol.Factory());
         org.apache.hive.service.rpc.thrift.TOpenSessionReq openSessionReq =
         new org.apache.hive.service.rpc.thrift.TOpenSessionReq();
         deserializer.deserialize(openSessionReq, data);
         openSessionReq.getConfiguration().forEach(
         (k, v) -> logger.info("AuthenticationHandler extractUserPass configuration: {}: {}", k, v));
         } catch (Exception e) {
         logger.error(e.getMessage(), e);

but occur fail.

How does Kyuubi source code parse the body encoded by thrift protocol from the client?

[pan3793]

This is part of thrift Java SDK, as an application, we just use the thrift rpc protocol, do not care much about the underlying transport layer.

[rubberliu]

Thanks! Could you please provide me with the location of the source code for this logic?
I am newbie for Kyuubi and try finding this logic.

[pan3793]

org.apache.thrift.transport.THttpClient might be a good entry point for code reading

[rubberliu]

Thanks!