Fix repeating number of rows

apache · Apr 18, 2021 · f93a7d3 · f93a7d3
1 parent c82efe7
commit f93a7d3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rust/datafusion/src/physical_plan/cartesian_join.rs b/rust/datafusion/src/physical_plan/cartesian_join.rs
@@ -223,7 +223,7 @@ fn build_batch(
                 .iter()
                 .map(|arr| {
                     let scalar = ScalarValue::try_from_array(arr, i)?;
-                    Ok(scalar.to_array_of_size(left.num_rows()))
+                    Ok(scalar.to_array_of_size(batch.num_rows()))
                 })
                 .collect::<Result<Vec<_>>>()
                 .map_err(|x| x.into_arrow_external_error())?;