|
@@ -46,7 +46,8 @@ class HiveDS(DataSourceBase):
|
|
|
conn = hive.Connection(host=self.host, port=self.port, username=self.username, database=self.database_name)
|
|
|
else:
|
|
|
get_kerberos_to_local(self.keytab)
|
|
|
- os.system(f'kiinit -kt {self.keytab} {self.principal}')
|
|
|
+ file_name = './configs/'+self.keytab.split("/")[-1]
|
|
|
+ os.system(f'kinit -kt {file_name} {self.principal}')
|
|
|
conn = hive.Connection(host=self.host, database=self.database_name, port=self.port, auth="KERBEROS", kerberos_service_name=self.kerberos_service_name)
|
|
|
|
|
|
|