java.lang.ClassCastException: cannot assign instance of java.lang.invoke.SerializedLambda to field org.apache.spark.api.java.JavaPairRDD$$anonfun$pairFunToScalaFun$1.x$334 of type org.apache.spark.api.java.function.PairFunction in instance of org.apache.spark.api.java.JavaPairRDD$$anonfun$pairFunToScalaFun$1
连接本地模式运行是正常的，连接远程spark集群运行就报错，按照网上说的设置了jars也报错，都百度烂了，求大佬帮忙啊

兄弟，问题解决了吗

问题解决了吗？

问题解决了吗

spark 不支持java1.8的Lambda， 改写成new 方法的的吧， 然后可能会报序列化错误， 然后排查， 然后会报其他错误 继续排查。。。。

解决了么

大佬们，解决了吗？我也遇到这个问题了