File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/parser Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff 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)
You can’t perform that action at this time.
0 commit comments