[
https://issues.apache.org/jira/browse/FLINK-33341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17779129#comment-17779129
]
Stefan Richter commented on FLINK-33341:
FYI, here is a link to the development branch:
[
https://issues.apache.org/jira/browse/FLINK-33341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17779124#comment-17779124
]
Stefan Richter commented on FLINK-33341:
[~Yanfei Lei], yes only the previous local state is
[
https://issues.apache.org/jira/browse/FLINK-33341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17779106#comment-17779106
]
Yanfei Lei commented on FLINK-33341:
Hi [~srichter]
IIUC, only subtasks that are assigned to the
[
https://issues.apache.org/jira/browse/FLINK-33341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778677#comment-17778677
]
Stefan Richter commented on FLINK-33341:
Exactly, we support local state for recovery - but not
[
https://issues.apache.org/jira/browse/FLINK-33341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778665#comment-17778665
]
Yun Tang commented on FLINK-33341:
--
Current FLIP-291 already supports local recovery with the adaptive