[
https://issues.apache.org/jira/browse/FLINK-33957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17801082#comment-17801082
]
Prabhu Joseph commented on FLINK-33957:
---------------------------------------
[~Yanfei Lei] Could you take a look into this? Any idea when this issue could
happen? Thanks.
> Generic Log-Based Incremental Checkpoint fails when Task Local Recovery is
> enabled
> ----------------------------------------------------------------------------------
>
> Key: FLINK-33957
> URL: https://issues.apache.org/jira/browse/FLINK-33957
> Project: Flink
> Issue Type: Bug
> Affects Versions: 1.17.1
> Reporter: Prabhu Joseph
> Priority: Major
>
> Generic Log-Based Incremental Checkpoint fails when Task Local Recovery is
> enabled. The issue happened to one of our users. I am trying to reproduce the
> issue.
> {code}
> at
> org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable.handleExecutionException(AsyncCheckpointRunnable.java:298)
> ~[flink-dist-1.17.1-amzn-1.jar:1.17.1-amzn-1]
> at
> org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable.run(AsyncCheckpointRunnable.java:155)
> ~[flink-dist-1.17.1-amzn-1.jar:1.17.1-amzn-1]
> ... 3 more
> Caused by: org.apache.flink.util.SerializedThrowable:
> java.lang.IllegalStateException: one checkpoint contains at most one
> materializationID
> at
> org.apache.flink.util.Preconditions.checkState(Preconditions.java:193)
> ~[flink-dist-1.17.1-amzn-1.jar:1.17.1-amzn-1]
> at
> org.apache.flink.runtime.state.ChangelogTaskLocalStateStore.updateReference(ChangelogTaskLocalStateStore.java:92)
> ~[flink-dist-1.17.1-amzn-1.jar:1.17.1-amzn-1]
> at
> org.apache.flink.runtime.state.ChangelogTaskLocalStateStore.storeLocalState(ChangelogTaskLocalStateStore.java:130)
> ~[flink-dist-1.17.1-amzn-1.jar:1.17.1-amzn-1]
> at
> org.apache.flink.runtime.state.TaskStateManagerImpl.reportTaskStateSnapshots(TaskStateManagerImpl.java:140)
> ~[flink-dist-1.17.1-amzn-1.jar:1.17.1-amzn-1]
> at
> org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable.reportCompletedSnapshotStates(AsyncCheckpointRunnable.java:237)
> ~[flink-dist-1.17.1-amzn-1.jar:1.17.1-amzn-1]
> at
> org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable.run(AsyncCheckpointRunnable.java:136)
> ~[flink-dist-1.17.1-amzn-1.jar:1.17.1-amzn-1]
> ... 3 more
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
