diff --git a/Cargo.toml b/Cargo.toml
index 64a60bb..c351dd1 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -4,17 +4,17 @@ resolver = "2"
 members = ["datafusion-federation"]
 
 [workspace.package]
-version = "0.4.7"
+version = "0.4.8"
 edition = "2021"
 license = "Apache-2.0"
 readme = "README.md"
 repository = "https://github.com/datafusion-contrib/datafusion-federation"
 
 [workspace.dependencies]
-arrow-json = "55"
+arrow-json = "56"
 async-stream = "0.3.5"
 async-trait = "0.1.83"
-datafusion = "49.0.0"
-datafusion-federation = { path = "./datafusion-federation", version = "0.4.7" }
+datafusion = { git = "https://github.com/apache/datafusion.git", rev = "fa1f8c1" }
+datafusion-federation = { path = "./datafusion-federation", version = "0.4.8" }
 futures = "0.3.31"
 tokio = { version = "1.41", features = ["full"] }
diff --git a/datafusion-federation/src/sql/analyzer.rs b/datafusion-federation/src/sql/analyzer.rs
index 1fb0772..92447a1 100644
--- a/datafusion-federation/src/sql/analyzer.rs
+++ b/datafusion-federation/src/sql/analyzer.rs
@@ -437,6 +437,7 @@ fn rewrite_table_scans_in_expr(
                 order_by,
                 window_frame: wf.params.window_frame,
                 null_treatment: wf.params.null_treatment,
+                distinct: wf.params.distinct,
             };
             Ok(Expr::WindowFunction(Box::new(WindowFunction {
                 fun: wf.fun,