Abh*_*and 5 apache-spark spark-streaming
改组文件和数据文件在工人的块管理器文件夹中存储多长时间?(spark-a0ab5241-1b5e-4c73-93ed-f37bbc479591)
我有一个火花流作业,其窗口持续时间为2小时,幻灯片间隔为15分钟。
当我在块管理器路径中执行以下命令时
find . -type f -cmin +150 -name "shuffle*" -exec ls {} \; //command to find the shuffle files older than 2 hours
Run Code Online (Sandbox Code Playgroud)
我看到很多文件,这意味着它们没有被清除,而我期望它们会被清除。甚至还有昨天的文件。
随后,此大小不断增加并占用磁盘空间。
请建议如何摆脱这种情况,并帮助您理解这种行为。
| 归档时间: |
|
| 查看次数: |
396 次 |
| 最近记录: |