在本地以setMaster["local[*]"]的模式运行,可以进mapPartition及mapPartitionWithIndex的方法,也可以取到里面的数据。
但是打成jar包后提交到spark集群运行后就不进mapPartition及mapPartitionWithIndex,也拿不到里面的数据了,
有哪位大神知道这是什么情况吗? 帮忙解答一下 在此谢谢了!
但是打成jar包后提交到spark集群运行后就不进mapPartition及mapPartitionWithIndex,也拿不到里面的数据了,
有哪位大神知道这是什么情况吗? 帮忙解答一下 在此谢谢了!
解决方案 »
- 如何建设真正的云数据中心?
- 【超体验】华为互联网云桌面体验指导
- LVS NAT模式,浏览器无法通过vip访问真实服务器的页面
- UPS电源需要多大???
- docker容器里面怎么更改内核参数呢
- Gplugin for eclipse怎么安装?
- spark 启动worker时出错,求解答
- 服务器架构设计问题求助
- 怎么利用 java api 实现 solr+hbase+Lily HBase Indexer 实现全文搜索?
- 不备案的网站需要用什么用的服务器
- 类实例里调用spark rdd 处理成员变量,结果不能保留
- 为什么在Flume中加入自定义interceptor会报出ClassNotFoundException
要不你贴代码出来看看?