fix test

Author: adriangb

datafusion/datasource-parquet/src/row_filter.rs

@@ -375,7 +375,10 @@ pub(crate) fn can_expr_be_pushed_down_with_schemas(
     expr: &Arc<dyn PhysicalExpr>,
     file_schema: &Schema,
 ) -> bool {
-    pushdown_columns(expr, file_schema).is_ok()
+    match pushdown_columns(expr, file_schema) {
+        Ok(Some(_)) => true,
+        Ok(None) | Err(_) => false,
+    }
 }
 
 /// Calculate the total compressed size of all `Column`'s required for

datafusion/datasource-parquet/src/source.rs

@@ -91,10 +91,7 @@ use object_store::ObjectStore;
 /// # let file_schema = Arc::new(Schema::empty());
 /// # let object_store_url = ObjectStoreUrl::local_filesystem();
 /// # let predicate = lit(true);
-/// let source = Arc::new(
-///     ParquetSource::default()
-///     .with_predicate(Arc::clone(&file_schema), predicate)
-/// );
+/// let source = Arc::new(ParquetSource::default().with_predicate(predicate));
 /// // Create a DataSourceExec for reading `file1.parquet` with a file size of 100MB
 /// let config = FileScanConfigBuilder::new(object_store_url, file_schema, source)
 ///    .with_file(PartitionedFile::new("file1.parquet", 100*1024*1024)).build();