@@ -63,7 +63,7 @@ pub fn expr_api() -> Result<()> {
     // "fluent"-style API:
     let expr = col("a") + lit(5);
 
-    // The same same expression can be created directly, with much more code:
+    // The same expression can be created directly, with much more code:
     let expr2 = Expr::BinaryExpr(BinaryExpr::new(
         Box::new(col("a")),
         Operator::Plus,
 
@@ -50,7 +50,7 @@ use futures::future::BoxFuture;
 /// Options that control the reading of CSV files.
 ///
 /// Note this structure is supplied when a datasource is created and
-/// can not not vary from statement to statement. For settings that
+/// can not vary from statement to statement. For settings that
 /// can vary statement to statement see
 /// [`ConfigOptions`](crate::config::ConfigOptions).
 #[derive(Clone)]
@@ -246,7 +246,7 @@ impl<'a> CsvReadOptions<'a> {
 /// Options that control the reading of Parquet files.
 ///
 /// Note this structure is supplied when a datasource is created and
-/// can not not vary from statement to statement. For settings that
+/// can not vary from statement to statement. For settings that
 /// can vary statement to statement see
 /// [`ConfigOptions`](crate::config::ConfigOptions).
 #[derive(Clone)]
@@ -357,7 +357,7 @@ impl<'a> ParquetReadOptions<'a> {
 /// Options that control the reading of ARROW files.
 ///
 /// Note this structure is supplied when a datasource is created and
-/// can not not vary from statement to statement. For settings that
+/// can not vary from statement to statement. For settings that
 /// can vary statement to statement see
 /// [`ConfigOptions`](crate::config::ConfigOptions).
 #[derive(Clone)]
@@ -403,7 +403,7 @@ impl<'a> ArrowReadOptions<'a> {
 /// Options that control the reading of AVRO files.
 ///
 /// Note this structure is supplied when a datasource is created and
-/// can not not vary from statement to statement. For settings that
+/// can not vary from statement to statement. For settings that
 /// can vary statement to statement see
 /// [`ConfigOptions`](crate::config::ConfigOptions).
 #[derive(Clone)]
 
@@ -1787,7 +1787,7 @@ impl LogicalPlan {
     /// updated according to the new parameters.
     ///
     /// Unlike `recompute_schema()`, this method rebuilds VALUES plans entirely to properly infer
-    /// types types from literal values after placeholder substitution.
+    /// types from literal values after placeholder substitution.
     fn update_schema_data_type(self) -> Result<LogicalPlan> {
         match self {
             // Build `LogicalPlan::Values` from the values for type inference.
 
@@ -475,7 +475,7 @@ pub enum WindowFrameUnits {
     Range,
     /// The GROUPS frame type means that the starting and ending boundaries are determine
     /// by counting "groups" relative to the current group. A "group" is a set of rows that all have
-    /// equivalent values for all all terms of the window ORDER BY clause.
+    /// equivalent values for all terms of the window ORDER BY clause.
     Groups,
 }
 
 
@@ -104,25 +104,25 @@ impl PhysicalSortExpr {
         result
     }
 
-    /// Set the sort sort options to ASC
+    /// Set the sort options to ASC
     pub fn asc(mut self) -> Self {
         self.options.descending = false;
         self
     }
 
-    /// Set the sort sort options to DESC
+    /// Set the sort options to DESC
     pub fn desc(mut self) -> Self {
         self.options.descending = true;
         self
     }
 
-    /// Set the sort sort options to NULLS FIRST
+    /// Set the sort options to NULLS FIRST
     pub fn nulls_first(mut self) -> Self {
         self.options.nulls_first = true;
         self
     }
 
-    /// Set the sort sort options to NULLS LAST
+    /// Set the sort options to NULLS LAST
     pub fn nulls_last(mut self) -> Self {
         self.options.nulls_first = false;
         self
 
@@ -161,7 +161,7 @@ impl<T> Drop for DistributionSender<T> {
             // During the shutdown of a empty channel, both the sender and the receiver side will be dropped. However we
             // only want to decrement the "empty channels" counter once.
             //
-            // We are within a critical section here, so we we can safely assume that either the last sender or the
+            // We are within a critical section here, so we can safely assume that either the last sender or the
             // receiver (there's only one) will be dropped first.
             //
             // If the last sender is dropped first, `state.data` will still exists and the sender side decrements the
 
@@ -164,7 +164,7 @@ contributions. Kudos to [@2010YOUY01] for the initial implementation.
 ## Documentation Examples
 
 We use Rust [doctest] to verify examples from the documentation are correct and
-up-to-date. These tests are run as part of our CI and you can run them them
+up-to-date. These tests are run as part of our CI and you can run them
 locally with the following command:
 
 ```shell
Original file line number	Diff line number	Diff line change
`@@ -475,7 +475,7 @@ pub enum WindowFrameUnits {`
`475`	`475`	`Range,`
`476`	`476`	`/// The GROUPS frame type means that the starting and ending boundaries are determine`
`477`	`477`	`/// by counting "groups" relative to the current group. A "group" is a set of rows that all have`
`478`		`- /// equivalent values for all all terms of the window ORDER BY clause.`
	`478`	`+ /// equivalent values for all terms of the window ORDER BY clause.`
`479`	`479`	`Groups,`
`480`	`480`	`}`
`481`	`481`