Skip to content

Commit 6bb5880

Browse files
baishuoliancheng
authored andcommitted
Update HiveQl.scala
1 parent c5414b6 commit 6bb5880

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
@@ -837,11 +837,6 @@ private[hive] object HiveQl {
837837
cleanIdentifier(key.toLowerCase) -> None
838838
}.toMap).getOrElse(Map.empty)
839839

840-
if (partitionKeys.values.exists(p => p.isEmpty)) {
841-
throw new NotImplementedError(s"Do not support INSERT INTO/OVERWRITE with" +
842-
s"dynamic partitioning.")
843-
}
844-
845840
InsertIntoTable(UnresolvedRelation(db, tableName, None), partitionKeys, query, overwrite)
846841

847842
case a: ASTNode =>

0 commit comments

Comments
 (0)