[
https://issues.apache.org/jira/browse/FLINK-33957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prabhu Joseph updated FLINK-33957:
----------------------------------
Description:
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}
was:
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
```
> 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)
