[jira] [Created] (FLINK-26799) StateChangeFormat#read not seek to offset correctly

["Feifan Wang (Jira)" <ji...@apache.org>]

Feifan Wang created FLINK-26799:
-----------------------------------

             Summary: StateChangeFormat#read not seek to offset correctly
                 Key: FLINK-26799
                 URL: https://issues.apache.org/jira/browse/FLINK-26799
             Project: Flink
          Issue Type: Bug
          Components: Runtime / State Backends
            Reporter: Feifan Wang


StateChangeFormat#read must seek to offset before read, current implement as follows :

 
{code:java}
FSDataInputStream stream = handle.openInputStream();
DataInputViewStreamWrapper input = wrap(stream);
if (stream.getPos() != offset) {
    LOG.debug("seek from {} to {}", stream.getPos(), offset);
    input.skipBytesToRead((int) offset);
}{code}
But the if condition is incorrect, stream.getPos() return the position of underlying stream which is different from position of input.

By the way, because of wrapped by BufferedInputStream, position of underlying stream always at n*bufferSize or the end of file. 

Actually, input is aways at position 0 at beginning, so I think we can seek to the offset directly.

 



--
This message was sent by Atlassian Jira
(v8.20.1#820001)