update

DazhuangSu · DazhuangSu · commit d725fc96804d · 2018-06-01T00:20:03.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,6 +57,7 @@ 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
@@ -548,7 +548,7 @@ case class AlterTableDropPartitionCommand(
             }
             val dataType = table.partitionSchema.apply(attrName).dataType
             expr.withNewChildren(Seq(AttributeReference(attrName, dataType)(),
-              Cast(Literal(value.toString), dataType)))
+              Cast(Literal(value), dataType)))
           }.reduce(And)
 
           val partitions = catalog.listPartitionsByFilter(

Original file line number	Diff line number	Diff line change
`@@ -548,7 +548,7 @@ case class AlterTableDropPartitionCommand(`
`548`	`548`	`}`
`549`	`549`	`val dataType = table.partitionSchema.apply(attrName).dataType`
`550`	`550`	`expr.withNewChildren(Seq(AttributeReference(attrName, dataType)(),`
`551`		`- Cast(Literal(value.toString), dataType)))`
	`551`	`+ Cast(Literal(value), dataType)))`
`552`	`552`	`}.reduce(And)`
`553`	`553`
`554`	`554`	`val partitions = catalog.listPartitionsByFilter(`