我指的是https://github.com/apache/spark/blob/master/examples/src/main/java/org/apache/spark/examples/streaming/javadirectkafkawordcount.java 并尝试构建spark wordcount示例，但有些代码没有在eclipse中编译，并显示下面的错误。
引发错误的代码是：

JavaDStream<String> words = lines.flatMap(new FlatMapFunction<String, String>() {
      @Override
      public Iterator<String> call(String x) {
        return Arrays.asList(SPACE.split(x)).iterator();
      }
    });

编译错误：
返回类型与flatmapfunction.call（字符串）不兼容
以下是详细信息：spark 1.6.1、Java1.7_、EclipseKepler、cdh5.7我尝试过更改jdk版本，并将所有HadoopJAR添加为外部jar、maven依赖项，但这个错误仍然存在。