java中的任务不可序列化错误

4szc88ey  于 2021-05-27  发布在  Spark
关注(0)|答案(0)|浏览(222)

我试图读取工作节点中的一个文件,如下所示,但它给出了一个错误,表示任务不可序列化。我的代码如下:

JavaPairRDD<String, String> rdd1 = pairs.reduceByKey(new Function2<String, String, String>() {
@Override
public String call(String v1, String v2) throws Exception {
    JavaRDD <String> br = sc.textFile("C:\\myFile.txt");
    return v1+v2;
    }
});

我怎样才能摆脱这个错误?非常感谢您的帮助。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题