Search before asking
Description
By default, the checkpoint directory of flink job on streampark is consist of base directory configured by parameter "state.checkpoints.dir" on flink-conf.yaml and job id. However, it leads a disaster to distinguish between difference flink job, and it is very difficult to clear checkpoints of unuseful flink job. So I wish streampark community can consider to add job name to checkpoints directory.
BTW, I think streampark can restrict the job name only use English alphabet, number and "-" etc. to protect the checkpoint directory is avaliable absolutely!
For example, there are some cases might be happened:
- Flink job upgrade/change/restart. Job Id of flink job changed so that ck directory also change.
- Delete unuseful flink job. Delete flink job but not checkpoint directory on streampark, it will be difficult clear after that.
- Delete checkpoint directory on streampark is difficult when flink job has made many checkpoints, only can delete it manually.
Usage Scenario
No response
Related issues
No response
Are you willing to submit a PR?
Code of Conduct
Search before asking
Description
By default, the checkpoint directory of flink job on streampark is consist of base directory configured by parameter "state.checkpoints.dir" on flink-conf.yaml and job id. However, it leads a disaster to distinguish between difference flink job, and it is very difficult to clear checkpoints of unuseful flink job. So I wish streampark community can consider to add job name to checkpoints directory.
BTW, I think streampark can restrict the job name only use English alphabet, number and "-" etc. to protect the checkpoint directory is avaliable absolutely!
For example, there are some cases might be happened:
Usage Scenario
No response
Related issues
No response
Are you willing to submit a PR?
Code of Conduct