[
https://issues.apache.org/jira/browse/FLINK-24064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407287#comment-17407287
]
Thomas Weise commented on FLINK-24064:
--------------------------------------
Exception restoring task/operator:
{code:java}
java.lang.NullPointerException: Source for index=1 not
availablejava.lang.NullPointerException: Source for index=1 not available at
org.apache.flink.util.Preconditions.checkNotNull(Preconditions.java:104) at
org.apache.flink.connector.base.source.hybrid.HybridSourceSplitSerializer.lambda$serializerOf$0(HybridSourceSplitSerializer.java:91)
at java.base/java.util.HashMap.computeIfAbsent(HashMap.java:1133) at
org.apache.flink.connector.base.source.hybrid.HybridSourceSplitSerializer.serializerOf(HybridSourceSplitSerializer.java:87)
at
org.apache.flink.connector.base.source.hybrid.HybridSourceSplitSerializer.deserializeV0(HybridSourceSplitSerializer.java:81)
at
org.apache.flink.connector.base.source.hybrid.HybridSourceSplitSerializer.deserialize(HybridSourceSplitSerializer.java:68)
at
org.apache.flink.connector.base.source.hybrid.HybridSourceSplitSerializer.deserialize(HybridSourceSplitSerializer.java:35)
at
org.apache.flink.core.io.SimpleVersionedSerialization.readVersionAndDeSerialize(SimpleVersionedSerialization.java:165)
at
org.apache.flink.streaming.api.operators.util.SimpleVersionedListState$DeserializingIterator.next(SimpleVersionedListState.java:138)
at java.base/java.util.Iterator.forEachRemaining(Iterator.java:133) at
org.apache.flink.util.CollectionUtil.iterableToList(CollectionUtil.java:95) at
org.apache.flink.streaming.api.operators.SourceOperator.open(SourceOperator.java:251)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:442)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:582)
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.executeRestore(StreamTask.java:562)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:647)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:537)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:759) at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:566) at
java.base/java.lang.Thread.run(Thread.java:829) {code}
> HybridSource recovery from savepoint fails
> ------------------------------------------
>
> Key: FLINK-24064
> URL: https://issues.apache.org/jira/browse/FLINK-24064
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Common
> Reporter: Thomas Weise
> Assignee: Thomas Weise
> Priority: Major
>
> Recovery fails because underlying source and split deserializers are not
> initialized in the restore code path. This requires deferred deserialization
> after the current source has been set.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
