java调用spark的api_spark java api 调用时报-CSDN博客

网站介绍:文章浏览阅读463次。java.lang.ClassNotFoundException: JavaWordCount$1在调用spark给的例子中,我们会碰到提交运行的时候会报空指针问题。那时因为spark集群中找不到你制定的class,所以我们需要手动的将包添加到当前的job中。以JavaWordCount为例,修改后的代码如下:备注:在运行的参数中需要设置==》spark://localhost:7077hdf..._: org/apache/spark/api/java/function/flatmapfunction