[jira] [Commented] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759873#comment-17759873 ] Yanfei Lei commented on FLINK-30863: Merged via c23a3002b837ecffa2d561a405c17c979c814c6e > Register

[jira] [Commented] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753869#comment-17753869 ] Feifan Wang commented on FLINK-30863: - Since [~Yanfei Lei]  is still working on the ticket, I

[jira] [Commented] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714399#comment-17714399 ] Yanfei Lei commented on FLINK-30863: [~Feifan Wang] Thanks for your proposal!  “2. delete by not

[jira] [Commented] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714392#comment-17714392 ] Feifan Wang commented on FLINK-30863: - There are two known issues with dstl file cleanup: # local

[jira] [Commented] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701000#comment-17701000 ] Yanfei Lei commented on FLINK-30863: [~assassinj] Thanks for your investigation and solutions,

[jira] [Commented] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1770#comment-1770 ] Feifan Wang commented on FLINK-30863: - Hi [~Yanfei Lei] , sorry for the late reply, I agree to

[jira] [Commented] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699956#comment-17699956 ] jinghaihang commented on FLINK-30863: - More to the point, I'm also confused about whether it's

[jira] [Commented] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699920#comment-17699920 ] jinghaihang commented on FLINK-30863: - [~Yanfei Lei]  Thanks for your reply. I don't think the

[jira] [Commented] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699621#comment-17699621 ] Yanfei Lei commented on FLINK-30863: [~assassinj] Thanks for sharing a new situation, I think it's

[jira] [Commented] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699586#comment-17699586 ] jinghaihang commented on FLINK-30863: - The above description can be simplified to the following

[jira] [Commented] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699585#comment-17699585 ] jinghaihang commented on FLINK-30863: - Hello Yanfei Lei, I found another situation that also