Я указал локальный путь для потоковой передачи текстового файла. Но он дает пустые результаты даже после добавления новых файлов. Путь существует, и он также не открыт. Подскажите, пожалуйста, как это исправить.
val pathFile:Path=new Path(
"file:\\\\\\D:\\sparklearning\\inputFileStreaming\\"
)
println(pathFile.toString())
val linesDStream = streamingContext.textFileStream(pathFile.toString)
linesDStream.foreachRDD(x=>println(x.toString()))