Fix

src/Disks/AsynchronousReadIndirectBufferFromRemoteFS.cpp

@@ -78,9 +78,10 @@ bool AsynchronousReadIndirectBufferFromRemoteFS::nextImpl()
     if (size)
     {
         BufferBase::set(impl->buffer().begin(), impl->buffer().size(), impl->offset());
-        prefetch_future = {};
+        impl->absolute_position += working_buffer.size();
     }
 
+    prefetch_future = {};
     return size;
 }
 

src/Disks/ReadIndirectBufferFromRemoteFS.cpp

@@ -64,6 +64,9 @@ bool ReadIndirectBufferFromRemoteFS::nextImpl()
     /// and assigned to current buffer.
     swap(*impl);
 
+    if (result)
+        impl->absolute_position += working_buffer.size();
+
     return result;
 }
 

src/IO/ReadBufferFromRemoteFS.cpp

@@ -75,10 +75,7 @@ bool ReadBufferFromRemoteFS::readImpl()
     auto result = current_buf->next();
     /// Assign result to current buffer.
     swap(*current_buf);
-
-    /// absolute position is shifted by a data size that was read in next() call above.
-    if (result)
-        absolute_position += working_buffer.size();
+    /// Absolute position is updated by *IndirectBufferFromRemoteFS only.
 
     return result;
 }