Skip to content

[Bug] [environment] When run in local mode flink-distribute-cache won't be clear after job finished #1426

@liumengkai

Description

@liumengkai

Search before asking

  • I had searched in the issues and found no similar issues.

What happened

When run in local mode flink-distribute-cache won't be clear after job finished.

Flink will make a directory named ‘flink-distributed-cache-xxx’ and It won't be cleared after finished job.
Specific flink code we can found in package(org.apache.flink.runtime.jobgraph) JobGraphUtils#addUserArtifactEntries

image

What you expected to happen

When we finished our job we delete all flink tmp directory

How to reproduce

Run a chunjun job in local mode

Anything else

No response

Version

master

Are you willing to submit PR?

  • Yes I am willing to submit a PR!

Code of Conduct

Metadata

Metadata

Assignees

No one assigned

    Labels

    bugSomething isn't working

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions