update

Author: chenkovsky

datafusion/core/src/physical_planner.rs

@@ -807,8 +807,7 @@ impl DefaultPhysicalPlanner {
                         Partitioning::Hash(runtime_expr, *n)
                     }
                     LogicalPartitioning::DistributeBy(expr) => {
-                        let n =
-                            session_state.config().options().execution.target_partitions;
+                        let n = input.output_partitioning().partition_count();
                         let runtime_expr = expr
                             .iter()
                             .map(|e| {