Skip to content

Commit dc24c41

Browse files
baishuoliancheng
authored andcommitted
Update HiveQl.scala
1 parent 983609a commit dc24c41

File tree

1 file changed

+0
-5
lines changed
  • sql/hive/src/main/scala/org/apache/spark/sql/hive

1 file changed

+0
-5
lines changed

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

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -827,11 +827,6 @@ private[hive] object HiveQl {
827827
cleanIdentifier(key.toLowerCase) -> None
828828
}.toMap).getOrElse(Map.empty)
829829

830-
if (partitionKeys.values.exists(p => p.isEmpty)) {
831-
throw new NotImplementedError(s"Do not support INSERT INTO/OVERWRITE with" +
832-
s"dynamic partitioning.")
833-
}
834-
835830
InsertIntoTable(UnresolvedRelation(db, tableName, None), partitionKeys, query, overwrite)
836831

837832
case a: ASTNode =>

0 commit comments

Comments
 (0)