Fix clippy error

datafusion/core/tests/physical_optimizer/enforce_distribution.rs

@@ -1201,10 +1201,9 @@ fn reorder_join_keys_to_left_input() -> Result<()> {
         let top_join_plan = if join_type == JoinType::Inner
             || join_type == JoinType::Left
             || join_type == JoinType::LeftAnti
+            || join_type == JoinType::LeftSemi
         {
             format!("HashJoinExec: mode=Partitioned, join_type={:?}, on=[(AA@1, a1@5), (B@2, b1@6), (C@3, c@2)], probe_side=Right, probe_keys=0", &join_type)
-        } else if join_type == JoinType::LeftSemi {
-            format!("HashJoinExec: mode=Partitioned, join_type={:?}, on=[(AA@1, a1@5), (B@2, b1@6), (C@3, c@2)], probe_side=Right, probe_keys=0", &join_type)
         } else if join_type == JoinType::Full {
             format!("HashJoinExec: mode=Partitioned, join_type={:?}, on=[(AA@1, a1@5), (B@2, b1@6), (C@3, c@2)]", &join_type)
         } else {

datafusion/optimizer/src/push_down_filter.rs

@@ -159,8 +159,9 @@ pub struct PushDownFilter {}
 /// For example:
 ///   - In an inner join, both sides are preserved, because each row of the output
 ///     maps directly to a row from each side.
-/// Evaluates the columns referenced in the given expression to see if they refer
-/// only to the left or right columns
+///
+///     Evaluates the columns referenced in the given expression to see if they refer
+///     only to the left or right columns
 #[derive(Debug)]
 struct ColumnChecker<'a> {
     /// schema of left join input

datafusion/physical-expr/src/expressions/dynamic_filters.rs

@@ -207,8 +207,9 @@ impl DynamicFilterPhysicalExpr {
     /// This should be called e.g.:
     /// - When we've computed the probe side's hash table in a HashJoinExec
     /// - After every batch is processed if we update the TopK heap in a SortExec using a TopK approach.
-    /// `key_count` specifies the number of keys currently tracked by the filter
-    /// and is used for observability.
+    ///
+    ///   `key_count` specifies the number of keys currently tracked by the filter
+    ///   and is used for observability.
     #[inline]
     pub fn update(
         &self,

datafusion/physical-plan/src/joins/hash_join.rs

@@ -730,14 +730,12 @@ impl DisplayAs for HashJoinExec {
                         match df.current() {
                             Ok(current) if current != lit(true) => {
                                 format!(
-                                    ", probe_filter=[{current}], probe_side={:?}, probe_keys={}",
-                                    probe_side, keys
+                                    ", probe_filter=[{current}], probe_side={probe_side:?}, probe_keys={keys}"
                                 )
                             }
-                            _ => format!(
-                                ", probe_side={:?}, probe_keys={}",
-                                probe_side, keys
-                            ),
+                            _ => {
+                                format!(", probe_side={probe_side:?}, probe_keys={keys}")
+                            }
                         }
                     }
                     None => "".to_string(),