Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-10346

MemoryStateBackend does not clean up checkpoint directory

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 1.5.3, 1.6.0, 1.7.0
    • Fix Version/s: 1.7.0
    • Labels:
      None

      Description

      The StateBackendLoader creates a random subdirectory under HighAvailabilityOptions.HA_STORAGE_PATH for the MemoryStateBackend if no checkpointing directory has been specified (see StateBackendLoader.java:246). The problem is that this directory gets never removed after the MemoryStateBackend is closed. It is important to clean up these created directories.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              till.rohrmann Till Rohrmann
            • Votes:
              1 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

              • Created:
                Updated: