|
|
@@ -97,7 +97,9 @@ class HiveDS(DataSourceBase):
|
|
|
file_name = './assets/kerberos/'+self.keytab.split("/")[-1]
|
|
|
else:
|
|
|
file_name = self.keytab
|
|
|
- os.system(f'kinit -kt {file_name} {self.principal}')
|
|
|
+ auth_res = os.system(f'kinit -kt {file_name} {self.principal}')
|
|
|
+ if auth_res != 0:
|
|
|
+ raise Exception('hive 连接失败')
|
|
|
# conn = hive.Connection(host=self.host, port=self.port, auth="KERBEROS", kerberos_service_name=self.kerberos_service_name, database=self.database_name)
|
|
|
conn = hive.connect(
|
|
|
thrift_transport=create_hive_kerberos_plain_transport(
|
