Skip to content

Commit 80571f7

Browse files
committed
Resolve the Kerberos service host default in _HiveClient
1 parent e7ec4ec commit 80571f7

1 file changed

Lines changed: 2 additions & 3 deletions

File tree

‎pyiceberg/catalog/hive.py‎

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -161,7 +161,7 @@ def __init__(
161161
self._uri = uri
162162
self._kerberos_auth = kerberos_auth
163163
self._kerberos_service_name = kerberos_service_name
164-
self._kerberos_service_host = kerberos_service_host
164+
self._kerberos_service_host = kerberos_service_host or urlparse(uri).hostname
165165
self._ugi = ugi.split(":") if ugi else None
166166
self._transport = self._init_thrift_transport()
167167
self._was_opened = False
@@ -172,8 +172,7 @@ def _init_thrift_transport(self) -> TTransport:
172172
if not self._kerberos_auth:
173173
return TTransport.TBufferedTransport(socket)
174174
else:
175-
host = self._kerberos_service_host or url_parts.hostname
176-
return TTransport.TSaslClientTransport(socket, host=host, service=self._kerberos_service_name)
175+
return TTransport.TSaslClientTransport(socket, host=self._kerberos_service_host, service=self._kerberos_service_name)
177176

178177
def _client(self) -> Client:
179178
protocol = TBinaryProtocol.TBinaryProtocol(self._transport)

0 commit comments

Comments
 (0)