fix hive warehouse path

qiuxin2012 · Nov 22, 2021 · 958e50d · 958e50d
1 parent 6f8f5cd
commit 958e50d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/examples/src/main/scala/org/apache/spark/examples/sql/hive/SparkHiveExample.scala b/examples/src/main/scala/org/apache/spark/examples/sql/hive/SparkHiveExample.scala
@@ -144,7 +144,8 @@ object SparkHiveExample {
     spark.sqlContext.setConf("hive.exec.dynamic.partition", "true")
     spark.sqlContext.setConf("hive.exec.dynamic.partition.mode", "nonstrict")
     // Create a Hive partitioned table using DataFrame API
-    df.write.partitionBy("key").format("hive").saveAsTable("hive_part_tbl")
+    df.write.partitionBy("key").format("hive")
+      .mode(SaveMode.Overwrite).saveAsTable("hive_part_tbl")
     // Partitioned column `key` will be moved to the end of the schema.
     sql("SELECT * FROM hive_part_tbl").show()
     // +-------+---+