Details
-
Bug
-
Status: Resolved
-
Critical
-
Resolution: Unresolved
-
None
-
None
Description
Suppose a flink application crashes while archiving, it leaves some instant files that should be deleted.
If the commit file is deleted but the in-flight file is left, when the flink application starts, it will scan and get the last pending instant and throw an exception.
So we need to delete non-commit file first, and then delete commit file.
Attachments
Issue Links
- links to