Spark报错:

Exception: It appears that you are attempting to broadcast an RDD or reference an RDD from an action or transformation. RDD transformations and actions can only be invoked by the driver, not inside of other transformations; for example, rdd1.map(lambda x: rdd2.values.count() * x) is invalid because the values transformation and count action cannot be performed inside of the rdd1.map transformation. For more information, see SPARK-5063.

RDD的嵌套可以执行,但是无法实现,内部的RDD无法执行行为操作。根据SPARK-5063,RDD的嵌套操作是不被允许的。

解决方案:将一个rdd进行action转换后,保存在内存中。

Spark报错It appears that you are attempting to broadcast an RDD or reference an RDD from an action相关推荐

  1. spark报错:invalid token

    启动spark报错,启动container失败,去看yarn的日志,显示invalid token, 经过排查是hadoop子节点的配置和主节点的配置不一致导致的,同步之后,问题解决. 转载于:htt ...

  2. hadoop 报错 there appears to be a gap in the edit log. we expected txitd 1, but got txid 14444

    hadoop 报错 there appears to be a gap in the edit log.  we expected txitd 1, but got txid 14444 原因: na ...

  3. Spark 中 JVM 内存使用及配置详情、spark报错与调优、Spark内存溢出OOM异常

    一般在我们开发spark程序的时候,从代码开发到上线以及后期的维护中,在整个过程中都需要涉及到调优的问题,即一开始需要考虑如何把代码写的更简洁高效调优(即代码优化),待开发测试完成后,提交任务时综合考 ...

  4. Spark报错:Error:scalac: Scala compiler JARs not found (module ‘Spark_two‘): C:\Users\沫小新\.m2\repo

    Spark报错: 找不到scala-compiler-2.11.8.jar的包 Error:scalac: Scala compiler JARs not found (module 'Spark_t ...

  5. kerberos 下运行spark 报错 Requested user hdfs is banned

    启动运行报错 main : run as user is hdfs main : requested yarn user is hdfs Requested user hdfs is bannedFa ...

  6. Spark 报错 DROP TABLE IF EXISTS should not show AnalysisException

    spark-sql 执行执行 drop table if exists xxxx 的时候,报错信息如下: DROP TABLE IF EXISTS should not show AnalysisEx ...

  7. Spark报错 Failed to send RPC xxx to/ip:43074 java.nio.channels.ClosedChannelException

    1.美图 2.背景 是这样的,我写了一个spark程序,然后,运行的时候,我kiill yarn掉这个程序,然后发现程序报个错然后继续运行了. 我在页面点击任务停止就没事,我页面点击是调用yarn a ...

  8. Spark报错: IOException: Bad connect ack with firstBadlink as xxx:500010

    1.美图 2.背景 执行一个spark任务报错,看着是spark structured streaming 写入到kaf INFO: Exception in createBlockOutputStr ...

  9. Spark报错:Bad response ERROR for block BP-78092257-8.xx-121xxx

    1.背景 一个spark 运行了一夜的程序突然报错 java.io.Exception : Bad response ERROR for block BP-78092257-8.xx-121xxx:b ...

最新文章

  1. 《英文计算机术语译名研究》,试定义几个多媒体技术用语
  2. 深入理解Java虚拟机04--类结构文件
  3. 系统部署文档_惊喜!Alibaba架构师终于发布“微服务架构与实践”文档
  4. 柿子不能和什么同吃?柿子相克食物大盘点
  5. 使用Jmeter对mysql进行性能测试入门
  6. Windows 2000服务器安全配置精华技巧
  7. 警告解决办法:class xxxx has virtual method but non-virtual destructor
  8. linux ftp win nt,Java中apache包中FTPClient读取win NT上的FTP服务器文件失败
  9. java json 替换属性值_java字符串转json取对象和属性值问题
  10. Tair ldb(leveldb存储引擎)实现介绍
  11. css图片精灵定位_CSS精灵图片(CSS sprite)使用心得
  12. 谷歌公司经典面试题扔鸡蛋的详细解读(一)
  13. 日历时间 linux,Linux查看日历
  14. 自由 Pascal 集成开发环境 Lazarus
  15. 面试笔试不懂的东西(更新第一次)
  16. GPIO口有关上拉电阻和下拉电阻推挽输出开漏(OD)和开集(OC)
  17. 什么是 LRU 算法?
  18. 有了黑科技加持,这个“无界零售样板间”要火
  19. fast-request-2.1.3 免费版
  20. 100以内质因数分解代码

热门文章

  1. Linear Regression 吴恩达机器学习实验一(线性回归)
  2. Tesseract训练如何加入中文常见字体
  3. eBay西班牙站点店铺流量如何?
  4. 无线互联网——WWAN篇
  5. MySQL实战解析底层---为什么表数据删掉一半,表文件大小不变
  6. 彻底理解傅里叶变换!
  7. Solaris 10 启用、重启和关闭服务svcadm svcs
  8. Java开源建站工具大汇总
  9. python能做什么日常_我用 Python 做些什么?
  10. 注册商标不知道选择哪类?一张图带你了解商标分类