Ist Spark-Streaming funktioniert sowohl mit "cp" als auch mit "mv"
Ich verwende Spark-Streaming
Mein Programm liest ständig Streams aus einem Hadoop-Ordner. Das Problem ist, dass der Spark-Job gestartet wird, wenn ich ihn in meinen Hadoop-Ordner kopiere (Hadoop fs -copyFromLocal), aber wenn ich ihn verschiebe (Hadoop fs -mv / hadoopsourcePath / * / destinationPath /) funktioniert nicht
Ist es eine Einschränkung des Funken-Streamings?
Ich habe eine andere Frage im Zusammenhang mit Funken-Streaming:Kann Funken-Streaming bestimmte Dateien auswählen