Skip to content

Commit 03e389a

Browse files
author
sparksburnitt
committed
Removed unsupported OVERWRITE keyword.
1 parent c0abbbd commit 03e389a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/scala/org/apache/spark/sql/hbase/HBaseSQLParser.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -209,11 +209,11 @@ class HBaseSQLParser extends SqlParser {
209209
}
210210

211211
// Load syntax:
212-
// LOAD DATA [LOCAL] INPATH filePath [OVERWRITE] INTO TABLE tableName [FIELDS TERMINATED BY char]
212+
// LOAD DATA [LOCAL] INPATH filePath INTO TABLE tableName [FIELDS TERMINATED BY char]
213213
protected lazy val load: Parser[LogicalPlan] =
214214
(LOAD ~> PARALL.?) ~ (DATA ~> LOCAL.?) ~
215215
(INPATH ~> stringLit) ~
216-
(opt(OVERWRITE) ~> INTO ~> TABLE ~> ident) ~
216+
(INTO ~> TABLE ~> ident) ~
217217
(FIELDS ~> TERMINATED ~> BY ~> stringLit).? <~ opt(";") ^^ {
218218
case isparall ~ isLocal ~ filePath ~ table ~ delimiter =>
219219
BulkLoadIntoTableCommand(

0 commit comments

Comments
 (0)