У меня есть текущий конвейер, в котором я делаю несколько преобразований в свой фрейм данных.
Важно вставить контрольные точки, чтобы обеспечить приемлемое время выполнения.
Однако время от времени я получаю эту ошибку с любой из контрольных точек:
Job aborted due to stage failure: Task creation failed: java.io.FileNotFoundException
No such file or directory: /checkpoints/...../rdd-1002/part-00003
Можете ли вы предложить.