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)