Skip to content

Commit a66885a

Browse files
committed
Reverts the "typo" fix
1 parent 9194fe1 commit a66885a

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlParser.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1017,7 +1017,8 @@ class SparkSqlAstBuilder(conf: SQLConf) extends AstBuilder {
10171017
entry("field.delim", ctx.fieldsTerminatedBy) ++
10181018
entry("serialization.format", ctx.fieldsTerminatedBy) ++
10191019
entry("escape.delim", ctx.escapedBy) ++
1020-
entry("collection.delim", ctx.collectionItemsTerminatedBy) ++
1020+
// The following typo is inherited from Hive...
1021+
entry("colelction.delim", ctx.collectionItemsTerminatedBy) ++
10211022
entry("mapkey.delim", ctx.keysTerminatedBy) ++
10221023
Option(ctx.linesSeparatedBy).toSeq.map { token =>
10231024
val value = string(token)

sql/hive/src/test/scala/org/apache/spark/sql/hive/HiveDDLCommandSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -578,7 +578,7 @@ class HiveDDLCommandSuite extends PlanTest {
578578
assert(source2.table == "table2")
579579
}
580580

581-
test("load data") {
581+
test("load data") {
582582
val v1 = "LOAD DATA INPATH 'path' INTO TABLE table1"
583583
val (table, path, isLocal, isOverwrite, partition) = parser.parsePlan(v1).collect {
584584
case LoadData(t, path, l, o, partition) => (t, path, l, o, partition)

0 commit comments

Comments
 (0)