We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d7315b3 commit 83b536cCopy full SHA for 83b536c
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/predicates.scala
@@ -265,6 +265,7 @@ case class CaseWhen(branches: Seq[Expression]) extends Expression {
265
false
266
} else {
267
val allCondBooleans = predicates.forall(_.dataType == BooleanType)
268
+ // both then and else val should be considered.
269
val dataTypesEqual = (values ++ elseValue).map(_.dataType).distinct.size <= 1
270
allCondBooleans && dataTypesEqual
271
}
0 commit comments