We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent eb95783 commit 9e796abCopy full SHA for 9e796ab
sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveShim.scala
@@ -729,8 +729,7 @@ private[client] class Shim_v0_13 extends Shim_v0_12 {
729
def unapply(expr: Expression): Option[Attribute] = {
730
expr match {
731
case attr: Attribute => Some(attr)
732
- case Cast(IntegralType(), StringType, _) => None
733
- case Cast(child @ AtomicType(), dt: AtomicType, _)
+ case Cast(child @ IntegralType(), dt: IntegralType, _)
734
if Cast.canUpCast(child.dataType.asInstanceOf[AtomicType], dt) => unapply(child)
735
case _ => None
736
}
0 commit comments