Skip to content

Commit 5d1ff3e

Browse files
committed
Fix compile error
1 parent e91a24e commit 5d1ff3e

File tree

1 file changed

+3
-3
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/parser

1 file changed

+3
-3
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/parser/AstBuilder.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -196,9 +196,9 @@ class AstBuilder extends SqlBaseBaseVisitor[AnyRef] with Logging {
196196
ctx: PartitionSpecContext): Map[String, Option[String]] = withOrigin(ctx) {
197197
val parts = ctx.expression.asScala.map { pVal =>
198198
expression(pVal) match {
199-
case UnresolvedAttribute(name :: Nil) =>
199+
case UnresolvedAttribute(name :: Nil, _) =>
200200
name -> None
201-
case cmp @ EqualTo(UnresolvedAttribute(name :: Nil), constant: Literal) =>
201+
case cmp @ EqualTo(UnresolvedAttribute(name :: Nil, _), constant: Literal) =>
202202
name -> Option(constant.toString)
203203
case _ =>
204204
throw new ParseException("Invalid partition filter specification", ctx)
@@ -219,7 +219,7 @@ class AstBuilder extends SqlBaseBaseVisitor[AnyRef] with Logging {
219219
expression(pVal) match {
220220
case EqualNullSafe(_, _) =>
221221
throw new ParseException("'<=>' operator is not allowed in partition specification.", ctx)
222-
case cmp @ BinaryComparison(UnresolvedAttribute(name :: Nil), constant: Literal) =>
222+
case cmp @ BinaryComparison(UnresolvedAttribute(name :: Nil, _), constant: Literal) =>
223223
cmp.withNewChildren(Seq(AttributeReference(name, StringType)(), constant))
224224
case _ =>
225225
throw new ParseException("Invalid partition filter specification", ctx)

0 commit comments

Comments
 (0)