Prabhu Joseph created FLINK-33957:
-------------------------------------
Summary: 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
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.
```
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
```
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
