关于mapreduce使用问题
做菜鸟分仓
在线上提交了mr，发现每天的购买数据都是一样的。于是线下又试了。
发现，map后，reduce public void reduce(Record key, Iterator<Record> values, TaskContext context) 方法中，values里的record的对象全是同一个。。这是什么鬼。。
下面是对象的引用：
com.aliyun.odps.mapred.bridge.WritableRecord@67b6d4ae
com.aliyun.odps.mapred.bridge.WritableRecord@67b6d4ae
com.aliyun.odps.mapred.bridge.WritableRecord@67b6d4ae
com.aliyun.odps.mapred.bridge.WritableRecord@67b6d4ae
com.aliyun.odps.mapred.bridge.WritableRecord@67b6d4ae
com.aliyun.odps.mapred.bridge.WritableRecord@67b6d4ae
com.aliyun.odps.mapred.bridge.WritableRecord@67b6d4ae
有谁也遇到过这种问题。。新手求指导啊！！！
写回答
-
回 楼主(识嘚唔识嘚) 的帖子这个是因为框架里values.next()拿到的record是复用的，可以通过record.toArray()拿到所有的列的数据。2016-06-07 14:05:14赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
