We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 97e9b2d commit befc755Copy full SHA for befc755
1 file changed
native/core/src/execution/operators/scan.rs
@@ -268,10 +268,10 @@ impl ScanExec {
268
// The JVM side exports constant columns (partition/missing) as 1-element arrays
269
// to avoid materializing N identical values. We detect and expand them here.
270
if actual_num_rows > 1 {
271
- for i in 0..inputs.len() {
272
- if inputs[i].len() == 1 {
273
- let scalar = ScalarValue::try_from_array(&inputs[i], 0)?;
274
- inputs[i] = scalar.to_array_of_size(actual_num_rows)?;
+ for col in &mut inputs {
+ if col.len() == 1 {
+ let scalar = ScalarValue::try_from_array(col, 0)?;
+ *col = scalar.to_array_of_size(actual_num_rows)?;
275
}
276
277
0 commit comments