Yun Gao created FLINK-23512:
-------------------------------
Summary: Check for illegal modifications of JobGraph with
partially finished operators
Key: FLINK-23512
URL: https://issues.apache.org/jira/browse/FLINK-23512
Project: Flink
Issue Type: Sub-task
Components: Runtime / Checkpointing
Affects Versions: 1.14.0
Reporter: Yun Gao
Besides the fully finished operators, we also would like to disable inserting
new operators before the partially finished operators:
# If keyed state is used and discarded after the tasks get finished in the
first run, then if we received new records target at these keys, the result
would be not right.
# Similarly, for normal operator subtasks, if new records are emitted and they
relies on the discarded states, the result would also be confused.
Thus we would first disable such cases.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
