我删除了我的spark流的检查点目录。
现在,没有错误,但是流没有拾取任何文件。
如何解决我的愚蠢错误? :)
我试图创建一个新的检查点目录并更改查询名,但无济于事
检查集群是否已启用trash。如果启用该功能,则将删除文件或目录,该文件或目录将被移至用户主目录中的.Trash目录,而不是被删除。
trash
.Trash
尝试使用以下路径检查您的检查点目录是否可用。
hdfs://<host>/user/<username>/.Trash/Current/<your_checkpoint_path>