fix

core/src/types/blocking_read/blocking_reader.rs

@@ -21,7 +21,6 @@ use std::ops::RangeBounds;
 
 use bytes::Buf;
 use bytes::BufMut;
-use log::debug;
 use rayon::prelude::*;
 
 use crate::raw::oio::BlockingRead;
@@ -85,7 +84,6 @@ impl BlockingReader {
         let mut bufs = Vec::new();
         let mut offset = start;
         let concurrent = self.options.concurrent() as u64;
-
 
         let (interval_size, mut intervals) = end
             .map(|end| {
@@ -116,15 +114,14 @@ impl BlockingReader {
             });
 
         loop {
-
             let results: Vec<Result<(usize, Buffer)>> = intervals
                 .into_par_iter()
                 .map(|(start, end)| -> Result<(usize, Buffer)> {
                     let limit = (end - start) as usize;
 
-                    let bs = self.inner.read_at(start as u64, limit)?;
+                    let bs = self.inner.read_at(start, limit)?;
                     let n = bs.remaining();
-                    
+
                     Ok((n, bs))
                 })
                 .collect();

core/src/types/operator/blocking_operator.rs

@@ -385,7 +385,11 @@ impl BlockingOperator {
         FunctionRead(OperatorFunction::new(
             self.inner().clone(),
             path,
-            (OpRead::default(), BytesRange::default(), OpReader::default()),
+            (
+                OpRead::default(),
+                BytesRange::default(),
+                OpReader::default(),
+            ),
             |inner, path, (args, range, options)| {
                 if !validate_path(&path, EntryMode::FILE) {
                     return Err(