We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2fc73d4 commit 09a7a0bCopy full SHA for 09a7a0b
1 file changed
src/chunked/arrow_converter.rs
@@ -250,8 +250,7 @@ impl<'a> Converter<'a> for Slice2Arrow<'a> {
250
schema.clone(),
251
);
252
253
- let (sender, mut receiver) = bounded::<RecordBatch>(10);
254
- // let (sender, receiver) = sync_channel::<RecordBatch>(100);
+ let (sender, mut receiver) = bounded::<RecordBatch>(100);
255
256
let t: JoinHandle<Result<format::FileMetaData>> = thread::spawn(move || {
257
'outer: loop {
0 commit comments