Search before asking
Fluss version
0.9.0 (latest release)
Please describe the bug 🐞
For the logic in getClientScannerIoTmpDir , when the job runs on Hadoop YARN, Flink’s TMP_DIRS may contain multiple directories. In the current codebase, this value is treated as a single path, which can cause data to be written to an incorrect location and lead to uncontrolled disk usage.
Solution
No response
Are you willing to submit a PR?
Search before asking
Fluss version
0.9.0 (latest release)
Please describe the bug 🐞
For the logic in
getClientScannerIoTmpDir, when the job runs on Hadoop YARN, Flink’sTMP_DIRSmay contain multiple directories. In the current codebase, this value is treated as a single path, which can cause data to be written to an incorrect location and lead to uncontrolled disk usage.Solution
No response
Are you willing to submit a PR?