This is an automated email from the ASF dual-hosted git repository.

agrove pushed a commit to branch comet-parquet-exec
in repository https://gitbox.apache.org/repos/asf/datafusion-comet.git

commit 4e525fc9af961d458c84f64900b71006d9a6f49b
Author: Andy Grove <[email protected]>
AuthorDate: Sat Nov 9 09:37:02 2024 -0700

    fix
---
 native/core/src/execution/datafusion/planner.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/native/core/src/execution/datafusion/planner.rs 
b/native/core/src/execution/datafusion/planner.rs
index c711b03d..285623a9 100644
--- a/native/core/src/execution/datafusion/planner.rs
+++ b/native/core/src/execution/datafusion/planner.rs
@@ -1038,7 +1038,7 @@ impl PhysicalPlanner {
 
                     let mut file_groups = vec![vec![]; partition_count];
                     files.iter().enumerate().for_each(|(idx, file)| {
-                        file_groups[partition_count % idx].push(file.clone());
+                        file_groups[idx % partition_count].push(file.clone());
                     });
 
                     let file_scan_config =


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to