[jira] [Commented] (FLINK-28206) EOFException on Checkpoint Recovery

[uharaqo (Jira)]

Title: Message Title

uharaqo commented on FLINK-28206   Re: EOFException on Checkpoint Recovery RetrievableStreamStateHandle#retrieveState() would be the code that failed on production. But this code failed on my local machine even with a valid metadata file downloaded from S3: new RetrievableStreamStateHandle(org.apache.flink.core.fs.Path.fromLocalFile(localFile), localFile.length()).retrieveState(); Error: Exception in thread "main" java.io.StreamCorruptedException: invalid stream header: 4960672D     at java.base/java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:940)     at java.base/java.io.ObjectInputStream.<init>(ObjectInputStream.java:379)     at org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.<init>(InstantiationUtil.java:68)     at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:615)     at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:595)     at org.apache.flink.runtime.state.RetrievableStreamStateHandle.retrieveState(RetrievableStreamStateHandle.java:59)     at DeserializationTest.main(DeserializationTest.java:35) Any thoughts? Add Comment   This message was sent by Atlassian Jira (v8.20.10#820010-sha1:ace47f9)