Comments

Author: Fokko

mkdocs/docs/configuration.md

@@ -269,14 +269,23 @@ catalog:
   default:
     uri: thrift://localhost:9083
     hive.hive2-compatible: true
-    hive.kerberos-authorization: true
+    hive.kerberos-authentication: true
     s3.endpoint: http://localhost:9000
 ```
 
-| Key                         | Example | Description                       |
-| --------------------------- | ------- | --------------------------------- |
-| hive.hive2-compatible       | true    | Using Hive 2.x compatibility mode |
-| hive.kerberos-authorization | true    | Using authentication via Kerberos |
+| Key                          | Example | Description                       |
+|------------------------------| ------- | --------------------------------- |
+| hive.hive2-compatible        | true    | Using Hive 2.x compatibility mode |
+| hive.kerberos-authentication | true    | Using authentication via Kerberos |
+
+When using Hive 2.x, make sure to set the compatibility flag:
+
+```yaml
+catalog:
+  default:
+...
+    hive.hive2-compatible: true
+```
 
 ### Glue Catalog
 

pyiceberg/catalog/hive.py

@@ -121,7 +121,7 @@
 HIVE2_COMPATIBLE = "hive.hive2-compatible"
 HIVE2_COMPATIBLE_DEFAULT = False
 
-HIVE_KERBEROS_AUTH = "hive.kerberos-authorization"
+HIVE_KERBEROS_AUTH = "hive.kerberos-authentication"
 HIVE_KERBEROS_AUTH_DEFAULT = False
 
 LOCK_CHECK_MIN_WAIT_TIME = "lock-check-min-wait-time"
@@ -163,11 +163,7 @@ def _init_thrift_client(self):
         self._client = Client(protocol)
 
     def __enter__(self) -> Client:
-        if not self._kerberos_auth:
-            self._transport.open()
-        else:
-            self._init_thrift_client()
-            self._transport.open()
+        self._transport.open()
 
         if self._ugi:
             self._client.set_ugi(*self._ugi)