Details
-
Bug
-
Status: Closed
-
Blocker
-
Resolution: Won't Fix
-
1.3.2, 1.4.0
-
None
-
None
Description
Originally reported on the ML: https://lists.apache.org/thread.html/22a2cf83de3107aa81a03a921325a191c29df8aa8676798fcd497199@%3Cuser.flink.apache.org%3E
If we have a chain of operators where multiple of them have operator state, detection of the context.isRestored() flag (of CheckpointedFunction) does not work correctly. It's best exemplified using this minimal example where both the source and the flatMap have state:
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env .addSource(new MaSource()).uid("source-1") .flatMap(new MaFlatMap()).uid("flatMap-1"); env.execute("testing");
If I do a savepoint with these UIDs, then change "source-1" to "source-2" and restore from the savepoint context.isRestored() still reports true for the source.
Attachments
Attachments
Issue Links
- is a clone of
-
FLINK-7623 Detecting whether an operator is restored doesn't work with chained state
- Closed