We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5ac7dd0 commit 900bbc3Copy full SHA for 900bbc3
src/query/storages/fuse/src/io/read/block/block_reader_native.rs
@@ -20,7 +20,6 @@ use std::ops::Range;
20
use std::time::Instant;
21
22
use common_arrow::arrow::array::Array;
23
-use common_arrow::arrow::datatypes::DataType;
24
use common_arrow::native::read::reader::NativeReader;
25
use common_arrow::native::read::NativeReadBuf;
26
use common_catalog::plan::PartInfoPtr;
src/query/storages/fuse/src/operations/mutation/parquet_delete_source.rs
@@ -224,7 +224,7 @@ impl Processor for ParquetDeleteSource {
224
if matches!(self.state, State::FilterData(..)) {
225
return Ok(Event::Sync);
226
}
227
- return Ok(Event::Async);
+ Ok(Event::Async)
228
229
230
fn process(&mut self) -> Result<()> {
0 commit comments