log query without partition prefix

roapi · May 28, 2024 · 59c6b0e · 59c6b0e
1 parent 524670a
commit 59c6b0e
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/datafusion/core/src/datasource/listing/helpers.rs b/datafusion/core/src/datasource/listing/helpers.rs
@@ -30,7 +30,7 @@ use arrow_array::Array;
 use arrow_schema::Fields;
 use futures::stream::FuturesUnordered;
 use futures::{stream::BoxStream, StreamExt, TryStreamExt};
-use log::{debug, trace};
+use log::{debug, trace, warn};
 
 use crate::{error::Result, scalar::ScalarValue};
 
@@ -367,6 +367,12 @@ pub async fn pruned_partition_list<'a>(
             _ => {}
         }
     }
+    if partitioned_table_path.is_none() {
+        warn!(
+            "table ({}) query without partition prefix: {:?}",
+            table_path, filters
+        );
+    }
     let partitions = list_partitions(
         store,
         partitioned_table_path.as_ref().unwrap_or(table_path),