update

DazhuangSu · DazhuangSu · commit defc9f11831c · 2018-06-01T22:27:50.000+08:00
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/literals.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/literals.scala
@@ -57,7 +57,6 @@ object Literal {
     case b: Byte => Literal(b, ByteType)
     case s: Short => Literal(s, ShortType)
     case s: String => Literal(UTF8String.fromString(s), StringType)
-    case s: UTF8String => Literal(s, StringType)
     case b: Boolean => Literal(b, BooleanType)
     case d: BigDecimal => Literal(Decimal(d), DecimalType(Math.max(d.precision, d.scale), d.scale))
     case d: JavaBigDecimal =>
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/command/ddl.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/command/ddl.scala
@@ -538,17 +538,17 @@ case class AlterTableDropPartitionCommand(
       val partitionSet = {
         if (partition._2.nonEmpty) {
           val parts = partition._2.map { expr =>
-            val (attrName, value) = expr match {
+            val (attrName, constant) = expr match {
               case BinaryComparison(UnresolvedAttribute(name :: Nil), constant: Literal) =>
-                (name, constant.value)
+                (name, constant)
             }
             if (!table.partitionColumnNames.exists(resolver(_, attrName))) {
               throw new AnalysisException(s"${attrName} is not a valid partition column " +
                 s"in table ${table.identifier.quotedString}.")
             }
             val dataType = table.partitionSchema.apply(attrName).dataType
             expr.withNewChildren(Seq(AttributeReference(attrName, dataType)(),
-              Cast(Literal(value), dataType)))
+              Cast(constant, dataType)))
           }.reduce(And)
 
           val partitions = catalog.listPartitionsByFilter(
