;;
Subject: Filestream can not recognize the copied file
Hi all,
I tested filestream today, my code looks like:
val fs = ssc.textFileStream(*)
erroelines = fs.filter( _.contains("erroe"))
erroelines.print
ssc.start()
when I edit a file and save it to the dir, it works well.
If i
Hi all,
I tested filestream today, my code looks like:
val fs = ssc.textFileStream(*)
erroelines = fs.filter( _.contains("erroe"))
erroelines.print
ssc.start()
when I edit a file and save it to the dir, it works well.
If i copy a file to the dir, it does work.
my issues are:
1, is it OK please
