开发者社区> 问答> 正文

pipelinedRDD?报错

为什么类型为"PipelinedRDD"的对象不能做collect、count、take操作,而正常的RDD就可以,二者有什么区别?只要对象是PipelinedRDD,就会报错:Exception in thread "stdin writer for R" java.lang.ClassCastException: java.lang.String cannot be cast to [B
        at edu.berkeley.cs.amplab.sparkr.RRDD$$anon$4$$anonfun$run$3.apply(RRDD.scala:300)
        at edu.berkeley.cs.amplab.sparkr.RRDD$$anon$4$$anonfun$run$3.apply(RRDD.scala:298)
        at scala.collection.Iterator$class.foreach(Iterator.scala:727)
        at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
        at edu.berkeley.cs.amplab.sparkr.RRDD$$anon$4.run(RRDD.scala:298)


展开
收起
爱吃鱼的程序员 2020-06-14 19:58:32 966 0
1 条回答
写回答
取消 提交回答
  • https://developer.aliyun.com/profile/5yerqm5bn5yqg?spm=a2c6h.12873639.0.0.6eae304abcjaIB

    把map方法或者reduce方法定义成了类方法,就会报这个错。改成内部方法或者静态方法

    2020-06-14 19:58:47
    赞同 展开评论 打赏
问答分类:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载