1.hive动态分区,只需进行以下设置
val spark = SparkSession.builder() .appName("hivetest") .master("local") .getOrCreate() spark.sql("SET hive.exec.dynamic.partition = true") spark.sql("SET hive.exec.dynamic.partition.mode = nonstrict ") ........ spark.stop()
1.hive动态分区,只需进行以下设置
val spark = SparkSession.builder() .appName("hivetest") .master("local") .getOrCreate() spark.sql("SET hive.exec.dynamic.partition = true") spark.sql("SET hive.exec.dynamic.partition.mode = nonstrict ") ........ spark.stop()