more comments

dilipbiswal · dilipbiswal · commit 17610689595f · 2018-05-05T23:55:28.000-07:00
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/TypeCoercion.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/TypeCoercion.scala
@@ -711,7 +711,7 @@ object TypeCoercion {
     private val acceptedTypes = Seq(IntegerType, ShortType, ByteType)
     override def coerceTypes(plan: LogicalPlan): LogicalPlan = plan transformAllExpressions {
       case s @ ReplicateRows(children) if s.children.nonEmpty && s.childrenResolved &&
-        s.children.head.dataType != LongType && acceptedTypes.contains(s.children.head.dataType) =>
+        acceptedTypes.contains(s.children.head.dataType) =>
         val castedExpr = Cast(s.children.head, LongType)
         ReplicateRows(Seq(castedExpr) ++ s.children.tail)
     }

Original file line number	Diff line number	Diff line change
`@@ -711,7 +711,7 @@ object TypeCoercion {`
`711`	`711`	`private val acceptedTypes = Seq(IntegerType, ShortType, ByteType)`
`712`	`712`	`override def coerceTypes(plan: LogicalPlan): LogicalPlan = plan transformAllExpressions {`
`713`	`713`	`case s @ ReplicateRows(children) if s.children.nonEmpty && s.childrenResolved &&`
`714`		`- s.children.head.dataType != LongType && acceptedTypes.contains(s.children.head.dataType) =>`
	`714`	`+ acceptedTypes.contains(s.children.head.dataType) =>`
`715`	`715`	`val castedExpr = Cast(s.children.head, LongType)`
`716`	`716`	`ReplicateRows(Seq(castedExpr) ++ s.children.tail)`
`717`	`717`	`}`