Handling error locally

bharath-techie · bharath-techie · commit 8b8a49e3c9b2 · 2025-11-30T12:42:27.000+05:30
Signed-off-by: bharath-techie &lt;bharath78910@gmail.com&gt;
diff --git a/datafusion/core/src/datasource/listing_table_factory.rs b/datafusion/core/src/datasource/listing_table_factory.rs
@@ -193,7 +193,9 @@ impl TableProviderFactory for ListingTableFactory {
 
         // Pre-warm statistics cache if collect_statistics is enabled
         if session_state.config().collect_statistics() {
-            let _ = table.list_files_for_scan(state, &[], None).await?;
+            if let Err(e) = table.list_files_for_scan(state, &[], None).await {
+                log::warn!("Failed to pre-warm statistics cache: {}", e);
+            }
         }
 
         Ok(Arc::new(table))

Original file line number	Diff line number	Diff line change
`@@ -193,7 +193,9 @@ impl TableProviderFactory for ListingTableFactory {`
`193`	`193`
`194`	`194`	`// Pre-warm statistics cache if collect_statistics is enabled`
`195`	`195`	`if session_state.config().collect_statistics() {`
`196`		`- let _ = table.list_files_for_scan(state, &[], None).await?;`
	`196`	`+ if let Err(e) = table.list_files_for_scan(state, &[], None).await {`
	`197`	`+ log::warn!("Failed to pre-warm statistics cache: {}", e);`
	`198`	`+ }`
`197`	`199`	`}`
`198`	`200`
`199`	`201`	`Ok(Arc::new(table))`