Skip to content

Commit cc8cfdd

Browse files
committed
fix clippy
1 parent 4af7cf5 commit cc8cfdd

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

src/query/storages/fuse/src/io/read/block/parquet/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ impl BlockReader {
118118
// corresponding field, and a default value has been declared for
119119
// the corresponding field.
120120
//
121-
// Yes, it is too obscure, we need to polish it later.
121+
// Yes, it is too obscure, we need to polish it SOON.
122122

123123
let value = match column_chunks.get(&field.column_id) {
124124
Some(DataItem::RawData(data)) => {

src/query/storages/fuse/src/operations/read/parquet_data_source_deserializer.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,7 @@ impl DeserializeDataTransform {
117117
let output_schema: DataSchema = (&output_schema).into();
118118
let (need_reserve_block_info, _) = need_reserve_block_info(ctx.clone(), plan.table_index);
119119

120-
let batch_size = ctx.get_settings().get_fuse_parquet_read_batch_size()? as usize;
120+
let batch_size = ctx.get_settings().get_fuse_parquet_read_batch_size()?;
121121
Ok(ProcessorPtr::create(Box::new(DeserializeDataTransform {
122122
ctx,
123123
table_index: plan.table_index,

0 commit comments

Comments
 (0)