fix

alamb · alamb · commit d6a3e22a3d42 · 2021-12-29T16:55:45.000-05:00
diff --git a/datafusion/src/optimizer/simplify_expressions.rs b/datafusion/src/optimizer/simplify_expressions.rs
@@ -405,7 +405,8 @@ impl<'a> Simplifier<'a> {
     /// Returns true if expr is nullable
     fn nullable(&self, expr: &Expr) -> Result<bool> {
         for schema in &self.schemas {
-            if expr.nullable(schema.as_ref())? {
+            // expr may be from another input
+            if expr.nullable(schema.as_ref()).unwrap_or(false) {
                 return Ok(true);
             }
         }

Original file line number	Diff line number	Diff line change
`@@ -405,7 +405,8 @@ impl<'a> Simplifier<'a> {`
`405`	`405`	`/// Returns true if expr is nullable`
`406`	`406`	`fn nullable(&self, expr: &Expr) -> Result<bool> {`
`407`	`407`	`for schema in &self.schemas {`
`408`		`- if expr.nullable(schema.as_ref())? {`
	`408`	`+ // expr may be from another input`
	`409`	`+ if expr.nullable(schema.as_ref()).unwrap_or(false) {`
`409`	`410`	`return Ok(true);`
`410`	`411`	`}`
`411`	`412`	`}`