Работает ли спарк-стриминг с «cp» и «mv»

Я использую искровую трансляцию

Моя программа непрерывно считывает потоки из папки hadoop. Проблема в том, что если я копирую в свою папку hadoop (hadoop fs -copyFromLocal), запускается задание spark, но если я перемещаюсь (hadoop fs -mv / hadoopsourcePath / * / destinationPath /), оно выполняет не работа .

Это ограничение потоков искры?

У меня есть еще один вопрос, связанный с потоковой передачей искр:Может ли потоковая передача выбрать определенные файлы

Ответы на вопрос(1)

Ваш ответ на вопрос