No teste final, aparece a mensagem:
AnalysisException: Path does not exist: file:/home/dgeison/spark_streaming_de_dados/csv
Entendo que o programa não está encontrando o caminho da pasta. Já revirei o código, e mesmo assim não encontro o erro. Estou mandando aqui o link do github para ver se podem me ajudar.
https://github.com/dgeison/spark_streaming_de_dados
imagens do erro:
Por favor!
