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