星火和Java：错误ClassCastException异常

Question

我下面正是这个例子 https://github.com/rathboma/hadoop-framework-examples/tree/master/spark 当我尝试运行，我得到这个消息：

java.lang.ClassCastException: org.apache.spark.api.java.Optional cannot be cast to com.google.common.base.Optional 

我不我怎样才能解决这个问题，因为我用我的新手火花。 谢谢！ 有什么建议吗？

Answer 1

这是因为您使用Spark 1.x来编译代码，但在Spark 2.x群集中运行您的应用程序。您可以更新pom.xml以使用Spark群集的相同版本，并且可能还需要更新代码，因为2.x和1.x不兼容。