Fix compilation errors and warnings

Cargo.toml

@@ -53,3 +53,4 @@ tpchgen = { git = "https://github.com/clflushopt/tpchgen-rs", rev = "c8d82343252
 tpchgen-arrow = { git = "https://github.com/clflushopt/tpchgen-rs", rev = "c8d823432528eed4f70fca5a1296a66c68a389a8" }
 parquet = "55.2.0"
 arrow = "55.2.0"
+tokio-stream = "0.1.17"

src/errors/mod.rs

@@ -1,3 +1,5 @@
+#![allow(clippy::upper_case_acronyms, clippy::vec_box)]
+
 use crate::errors::datafusion_error::DataFusionErrorProto;
 use datafusion::common::internal_datafusion_err;
 use datafusion::error::DataFusionError;

src/flight_service/mod.rs

@@ -1,7 +1,6 @@
 mod do_get;
 mod service;
 mod session_builder;
-mod stream_partitioner_registry;
 
 pub(crate) use do_get::DoGet;
 

src/lib.rs

@@ -1,3 +1,5 @@
+#![deny(clippy::all)]
+
 mod channel_manager;
 mod common;
 mod composed_extension_codec;

src/test_utils/plan.rs

@@ -3,9 +3,7 @@ use datafusion::common::plan_err;
 use datafusion::common::tree_node::{Transformed, TreeNode};
 use datafusion::error::DataFusionError;
 use datafusion::physical_expr::Partitioning;
-use datafusion::physical_optimizer::PhysicalOptimizerRule;
 use datafusion::physical_plan::aggregates::{AggregateExec, AggregateMode};
-use datafusion::physical_plan::repartition::RepartitionExec;
 use datafusion::physical_plan::ExecutionPlan;
 use std::sync::Arc;