diff --git a/datafusion/physical-expr/src/expressions/get_indexed_field.rs b/datafusion/physical-expr/src/expressions/get_indexed_field.rs index 58fe4728543d..68149d769d60 100644 --- a/datafusion/physical-expr/src/expressions/get_indexed_field.rs +++ b/datafusion/physical-expr/src/expressions/get_indexed_field.rs @@ -217,9 +217,11 @@ impl PhysicalExpr for GetIndexedFieldExpr { fn nullable(&self, input_schema: &Schema) -> Result { let arg_dt = self.arg.data_type(input_schema)?; - self.schema_access(input_schema)? - .get_accessed_field(&arg_dt) - .map(|f| f.is_nullable()) + Ok(self.arg.nullable(input_schema)? + || self + .schema_access(input_schema)? + .get_accessed_field(&arg_dt) + .map(|f| f.is_nullable())?) } fn evaluate(&self, batch: &RecordBatch) -> Result { diff --git a/datafusion/physical-plan/src/metrics/mod.rs b/datafusion/physical-plan/src/metrics/mod.rs index fd16baae1446..b563271ee8fe 100644 --- a/datafusion/physical-plan/src/metrics/mod.rs +++ b/datafusion/physical-plan/src/metrics/mod.rs @@ -312,7 +312,7 @@ impl MetricsSet { pub fn clear(&mut self) { self.metrics.clear(); - } + } } impl Display for MetricsSet {