diff --git a/Cargo.toml b/Cargo.toml
index 36ce194..4dd397b 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -11,10 +11,10 @@ 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 = "50.0.0"
 datafusion-federation = { path = "./datafusion-federation", version = "0.4.9" }
 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..3303cce 100644
--- a/datafusion-federation/src/sql/analyzer.rs
+++ b/datafusion-federation/src/sql/analyzer.rs
@@ -437,6 +437,8 @@ fn rewrite_table_scans_in_expr(
                 order_by,
                 window_frame: wf.params.window_frame,
                 null_treatment: wf.params.null_treatment,
+                distinct: wf.params.distinct,
+                filter: wf.params.filter,
             };
             Ok(Expr::WindowFunction(Box::new(WindowFunction {
                 fun: wf.fun,
diff --git a/datafusion-federation/src/sql/ast_analyzer.rs b/datafusion-federation/src/sql/ast_analyzer.rs
index e974d24..5dee009 100644
--- a/datafusion-federation/src/sql/ast_analyzer.rs
+++ b/datafusion-federation/src/sql/ast_analyzer.rs
@@ -12,7 +12,7 @@ use super::AstAnalyzer;
 
 pub fn replace_table_args_analyzer(mut visitor: TableArgReplace) -> AstAnalyzer {
     let x = move |mut statement: Statement| {
-        VisitMut::visit(&mut statement, &mut visitor);
+        let _ = VisitMut::visit(&mut statement, &mut visitor);
         Ok(statement)
     };
     Box::new(x)