Fix nullability of CaseWhen.

ueshin · ueshin · commit 4f049cc94954 · 2014-06-19T18:49:33.000+09:00
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/predicates.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/predicates.scala
@@ -236,7 +236,7 @@ case class CaseWhen(branches: Seq[Expression]) extends Expression {
 
   override def nullable = {
     // If no value is nullable and no elseValue is provided, the whole statement defaults to null.
-    values.exists(_.nullable) || (values.length % 2 == 0)
+    values.exists(_.nullable) || (branches.length % 2 == 0)
   }
 
   override lazy val resolved = {

Original file line number	Diff line number	Diff line change
`@@ -236,7 +236,7 @@ case class CaseWhen(branches: Seq[Expression]) extends Expression {`
`236`	`236`
`237`	`237`	`override def nullable = {`
`238`	`238`	`// If no value is nullable and no elseValue is provided, the whole statement defaults to null.`
`239`		`- values.exists(_.nullable) \|\| (values.length % 2 == 0)`
	`239`	`+ values.exists(_.nullable) \|\| (branches.length % 2 == 0)`
`240`	`240`	`}`
`241`	`241`
`242`	`242`	`override lazy val resolved = {`