Open LuisMoralesAlonso opened 2 years ago
This worked for me (overriding the internal method that provides the tprotocol), provided I'm already performed a kinit:
class KerberosHiveMetastoreClient(HiveMetastoreClient):
@staticmethod
def _init_protocol(host: str, port: int) -> TBinaryProtocol:
transport = TSocket.TSocket(host, int(port))
transport = TTransport.TSaslClientTransport(transport, host=host, service="hive")
transport = TTransport.TBufferedTransport(transport)
return TBinaryProtocol.TBinaryProtocol(transport)
Does this client works ith Kerberos authentication i activated in Hive Metastore Service?