Spark Streaming中的ssc.textFileStream()，获取不到数据

wx_RYClUEop 发表于 2017-2-21 19:34
请问层主，这个问题解决了吗？我看了好几个帖子，都是只有问题，都没有解决办法

def textFileStream(directory: String): DStream[String]
Permalink
Create an input stream that monitors a Hadoop-compatible filesystem for new files and reads them as text files (using key as LongWritable, value as Text and input format as TextInputFormat).

上面是官网解释。
也就是，
1.首先参数必须是目录，而不能是指定文件
2.目录中的文件必须是text文件。
二者哪一个不符合都可能读不到数据。

可以更换为fileStream，不过需要版本支持。
streamingContext.fileStream[keyClass, valueClass, inputFormatClass](dataDirectory)
更多可参考
Spark中文手册3：Spark之基本概念
http://www.aboutyun.com/forum.php?mod=viewthread&tid=11502

都没有人解决这个问题吗，过了这么久了