lint

pola-rs · Oct 5, 2024 · 031bf29 · 031bf29
1 parent 8dc99b1
commit 031bf29
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/crates/polars-io/src/csv/read/read_impl.rs b/crates/polars-io/src/csv/read/read_impl.rs
@@ -403,7 +403,7 @@ impl<'a> CoreReader<'a> {
         let n_threads = self.n_threads.unwrap_or_else(|| POOL.current_num_threads());
         let n_parts_hint = n_threads * 32;
         let chunk_size = std::cmp::min(bytes.len() / n_parts_hint, 1024 * 128);
-        let mut chunk_size = std::cmp::max(chunk_size, 32);
+        let mut chunk_size = std::cmp::max(chunk_size, 1024 * 4);
         let mut total_bytes_offset = 0;
 
         let results = Arc::new(Mutex::new(vec![]));