Merge branch 'main' into er/fix/read_buffer/pred_validate
commit
c10f3258da
|
@ -198,7 +198,6 @@ where
|
||||||
let mut flights = vec![schema_flight_data];
|
let mut flights = vec![schema_flight_data];
|
||||||
|
|
||||||
for batch in results {
|
for batch in results {
|
||||||
warn!("batch {}", batch.num_rows());
|
|
||||||
let batch = optimize_record_batch(&batch, Arc::clone(&schema))?;
|
let batch = optimize_record_batch(&batch, Arc::clone(&schema))?;
|
||||||
|
|
||||||
let (flight_dictionaries, flight_batch) =
|
let (flight_dictionaries, flight_batch) =
|
||||||
|
|
Loading…
Reference in New Issue