Skip to content

Commit ca7ae7c

Browse files
add comments
1 parent 86caf2c commit ca7ae7c

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -509,6 +509,8 @@ private[hive] object HiveContext {
509509
val tempDir = Utils.createTempDir()
510510
val localMetastore = new File(tempDir, "metastore").getAbsolutePath
511511
val propMap: HashMap[String, String] = HashMap()
512+
// We have to mask all properties in hive-site.xml that relates to metastore data source
513+
// as we used a local metastore here.
512514
HiveConf.ConfVars.values().foreach { confvar =>
513515
if (confvar.varname.contains("datanucleus") || confvar.varname.contains("jdo")) {
514516
propMap.put(confvar.varname, confvar.defaultVal)

0 commit comments

Comments
 (0)