diff --git a/src/prism/logstream/mod.rs b/src/prism/logstream/mod.rs
index fe9fe9ef7..b15e1907d 100644
--- a/src/prism/logstream/mod.rs
+++ b/src/prism/logstream/mod.rs
@@ -336,7 +336,7 @@ impl PrismDatasetRequest {
         field: &str,
     ) -> Result<Vec<String>, QueryError> {
         let query = Query {
-            query: format!("SELECT DISTINCT({field}) FOR {stream_name}"),
+            query: format!("SELECT DISTINCT({field}) FROM {stream_name}"),
             start_time: "1h".to_owned(),
             end_time: "now".to_owned(),
             send_null: false,