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