Roman Khachatryan created FLINK-25260:
-----------------------------------------
Summary: Recovery fails when using changelog+s3+presto
Key: FLINK-25260
URL: https://issues.apache.org/jira/browse/FLINK-25260
Project: Flink
Issue Type: Bug
Components: Connectors / FileSystem, Runtime / State Backends
Reporter: Roman Khachatryan
Recovery succeeds if using local FS or hadoop S3 plugin, but fails with Presto:
{code}
Caused by: java.lang.IllegalStateException
at org.apache.flink.util.Preconditions.checkState(Preconditions.java:177)
at
org.apache.flink.changelog.fs.StateChangeFormat$1.readChange(StateChangeFormat.java:138)
at
org.apache.flink.changelog.fs.StateChangeFormat$1.next(StateChangeFormat.java:129)
at
org.apache.flink.changelog.fs.StateChangeFormat$1.next(StateChangeFormat.java:98)
at
org.apache.flink.runtime.state.changelog.StateChangelogHandleStreamHandleReader$1.next(StateChangelogHandleStreamHandleReader.java:76)
at
org.apache.flink.runtime.state.changelog.StateChangelogHandleStreamHandleReader$1.next(StateChangelogHandleStreamHandleReader.java:61)
at
org.apache.flink.state.changelog.restore.ChangelogBackendRestoreOperation.readBackendHandle(ChangelogBackendRestoreOperation.java:94)
at
org.apache.flink.state.changelog.restore.ChangelogBackendRestoreOperation.restore(ChangelogBackendRestoreOperation.java:74)
at
org.apache.flink.state.changelog.ChangelogStateBackend.restore(ChangelogStateBackend.java:221)
at
org.apache.flink.state.changelog.ChangelogStateBackend.createKeyedStateBackend(ChangelogStateBackend.java:145)
at
org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.lambda$keyedStatedBackend$1(StreamTaskStateInitializerImpl.java:329)
at
org.apache.flink.streaming.api.operators.BackendRestorerProcedure.attemptCreateAndRestore(BackendRestorerProcedure.java:168)
at
org.apache.flink.streaming.api.operators.BackendRestorerProcedure.createAndRestore(BackendRestorerProcedure.java:135)
... 13 more
{code}
This is likely caused by some intermediate buffers
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
