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

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

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

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

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

暂无答案!

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

相关问题