Spark Java错误：源代码1.5[重复]中不支持lambda表达式

Question

JavaRDD<String> lines = sc.textFile(logFile);
JavaPairRDD<String, Integer> pairs = lines.mapToPair(s -> new Tuple2(s, 1));

但是下面的代码工作得非常好。你能帮我找出原因吗？

JavaRDD<String> lines = sc.textFile(logFile);
JavaPairRDD<String, String> prodPairs = lines.mapToPair(new PairFunction<String, String, String>() {
            public Tuple2<String, String> call(String s) {
                String[] prodSplit = s.split(",");
                return new Tuple2<String, String>(prodSplit[2], prodSplit[0]+","+prodSplit[1]+","+prodSplit[2]); 
            }
        });

Answer 1

你在用Maven吗？

默认情况下，maven使用java 1.5的源代码和目标编译：

还要注意，目前默认的source设置是1.5，默认的target设置是1.5，与运行Maven的JDK无关。如果要更改这些默认值，应该按照设置Java编译器的-source和-target中的描述设置source和target。来源

<build>
    <plugins>
        <plugin>
            <groupId>org.apache.maven.plugins</groupId>
            <artifactId>maven-compiler-plugin</artifactId>
            <version>3.2</version>
            <configuration>
                <source>1.8</source>
                <target>1.8</target>
            </configuration>
        </plugin>
    </plugins>
</build>