Dear flink community,

I have following state class ( irrelevant fields removed )
public class MultiStorePacketState implements Serializable {

    public transient RandomAccessFile currentFile = null;
    public long timerValue;
    public String fileName;
    public String exportedFileName;
    public String sessionKey;
    public long fileOffset = 0;

}

Once in a while, currentFile became *nullified, *this happens after I
extract state via

MultiStorePacketState so = state.value();

The frequency of this behaviour is similar to checkpoint interval (
checkpoint interval defined as 5 seconds and first occurence of this
problem is also 5 seconds), otherwise I don't have any clues to a
possible explanation.

Is it an expected side effect of checkpoint procedure ?

Best regards,
Alex

Reply via email to