File tree Expand file tree Collapse file tree 1 file changed +1
-1
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer Expand file tree Collapse file tree 1 file changed +1
-1
lines changed Original file line number Diff line number Diff line change @@ -101,7 +101,7 @@ object NullPropagation extends Rule[LogicalPlan] {
101101 def apply (plan : LogicalPlan ): LogicalPlan = plan transform {
102102 case q : LogicalPlan => q transformExpressionsUp {
103103 case e @ Count (Literal (null , _)) => Cast (Literal (0L ), e.dataType)
104- case e @ Sum (Literal (c, _)) if c == 0 => Cast (Literal (0 ), e.dataType)
104+ case e @ Sum (Literal (c, _)) if c == 0 => Cast (Literal (0L ), e.dataType)
105105 case e @ Average (Literal (c, _)) if c == 0 => Literal (0.0 , e.dataType)
106106 case e @ IsNull (c) if c.nullable == false => Literal (false , BooleanType )
107107 case e @ IsNotNull (c) if c.nullable == false => Literal (true , BooleanType )
You can’t perform that action at this time.
0 commit comments