From 274fa3dd14c8e00966a802541b67b2886ca2466d Mon Sep 17 00:00:00 2001
From: hoslo <ys952572463@gmail.com>
Date: Sun, 28 Apr 2024 11:31:52 +0800
Subject: [PATCH] fix

---
 core/src/types/blocking_read/blocking_reader.rs | 7 ++-----
 core/src/types/operator/blocking_operator.rs    | 6 +++++-
 2 files changed, 7 insertions(+), 6 deletions(-)

diff --git a/core/src/types/blocking_read/blocking_reader.rs b/core/src/types/blocking_read/blocking_reader.rs
index a6403f87ab93..103c6c2ae76b 100644
--- a/core/src/types/blocking_read/blocking_reader.rs
+++ b/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();
diff --git a/core/src/types/operator/blocking_operator.rs b/core/src/types/operator/blocking_operator.rs
index 68361fac5416..9cd7ee41e406 100644
--- a/core/src/types/operator/blocking_operator.rs
+++ b/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(