Работает ли спарк-стриминг с «cp» и «mv»
Я использую искровую трансляцию
Моя программа непрерывно считывает потоки из папки hadoop. Проблема в том, что если я копирую в свою папку hadoop (hadoop fs -copyFromLocal), запускается задание spark, но если я перемещаюсь (hadoop fs -mv / hadoopsourcePath / * / destinationPath /), оно выполняет не работа .
Это ограничение потоков искры?
У меня есть еще один вопрос, связанный с потоковой передачей искр:Может ли потоковая передача выбрать определенные файлы