-
Type:
Sub-task
-
Status: Resolved
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: 3.0.0-alpha2
-
Fix Version/s: 3.0.0-alpha4, 2.9.1
-
Component/s: fs/oss
-
Labels:None
-
Hadoop Flags:Reviewed
public synchronized void seek(long pos) throws IOException { checkNotClosed(); if (position == pos) { return; } else if (pos > position && pos < position + partRemaining) { AliyunOSSUtils.skipFully(wrappedStream, pos - position); position = pos; } else { reopen(pos); } }
In seek function, we need to update the partRemaining when the seeking position is located in downloaded part.