擅长:python、mysql、java
<p>我不知道pyspark,但我使用的是scala下面的代码,它从去年开始工作。如果您可以在python中更改此代码。替换基于kerberos的属性值。在</p>
<pre><code>System.setProperty("hive.metastore.uris", "add hive.metastore.uris url");
System.setProperty("hive.metastore.sasl.enabled", "true")
System.setProperty("hive.metastore.kerberos.keytab.file", "add keytab")
System.setProperty("hive.security.authorization.enabled", "false")
System.setProperty("hive.metastore.kerberos.principal", "replace hive.metastore.kerberos.principal value")
System.setProperty("hive.metastore.execute.setugi", "true")
val hiveContext = new HiveContext(sparkContext)
</code></pre>