已删除火花检查点目录,现在不起作用

问题描述 投票:0回答:1

我删除了我的spark流的检查点目录。

现在,没有错误,但是流没有拾取任何文件。

如何解决我的愚蠢错误? :)

我试图创建一个新的检查点目录并更改查询名,但无济于事

apache-spark pyspark apache-spark-sql spark-streaming
1个回答
0
投票

检查集群是否已启用trash。如果启用该功能,则将删除文件或目录,该文件或目录将被移至用户主目录中的.Trash目录,而不是被删除。

尝试使用以下路径检查您的检查点目录是否可用。

hdfs://<host>/user/<username>/.Trash/Current/<your_checkpoint_path>

© www.soinside.com 2019 - 2024. All rights reserved.