一个mapreduce，非常诡异的问题，急求为什么？

      

@Override
        protected void reduce(Text key, Iterable<RecordBean> values,Context context)
                throws IOException, InterruptedException {
            RecordBean[]  beans = new RecordBean[2];
            Iterator<RecordBean> iter = values.iterator();
            int i  = 0;
            while(iter.hasNext()){
                beans[i] = iter.next();
                mos.write("info", beans[i].getKeyString(),beans[i].getCompString() + "-" +beans[i]);
                //这里输出,很明显其中日期是不一样的
                //13755556666    changchun20140202haha24-13755556666|changchun|20140202|haha|24
                //13755556666    changchun20140101haha24-13755556666|changchun|20140101|haha|24
                i = i+1;
            }
            if(beans.length == 2 && beans[0].equals(beans[1])){
                mos.write("same",beans[0].getKeyString(),beans[0]);
                mos.write("same",beans[1].getKeyString(),beans[1]);
                //但在这里有一样了，这是为什么？
                //13755556666    13755556666|changchun|20140101|haha|24
                //13755556666    13755556666|changchun|20140101|haha|24
            }else{
                mos.write("unsame", beans[0].getKeyString(),beans[0]);
            }        
        }
复制代码

需求是这样的，每个redude会输入1-2条记录，
如果2条记录相等，输入到一个same文件里面。
如果不相等，输入到一个unsame文件里面。

但是很诡异的问题出现了，在iter给RecordBean赋值的时候，两条记录是不一样的。
但在下面做判断输出的时候，输出的记录是一样的？
why？搞不明白了？多谢各位大神，给研究啊研究啊！

改成这样：看看效果

if(beans.length == 2 && beans[0]！=beans[1]){
mos.write("unsame",beans[0].getKeyString(),beans[0]);
mos.write("unsame",beans[1].getKeyString(),beans[1]);

}else{
mos.write("same", beans[0].getKeyString(),beans[0]);
}
复制代码

jixianqiuxue 发表于 2015-3-21 12:48
改成这样：看看效果

问题仍然存在，晕了！

狒狒 发表于 2015-3-21 12:58
问题仍然存在，晕了！

截图出来，这样应该没有问题了

jixianqiuxue 发表于 2015-3-21 12:59
截图出来，这样应该没有问题了

大神，你好。我真的没有必要骗你，按你说的改完之后，输出是一样的！
我想问问你的判断是什么？
==  是判断内存的手地址
equals 是判断内容，我自己重写的！
但是这2中判断，尽然结果都是一样的，神奇！

附上我的equals方法

@Override
        public boolean equals(Object obj) {
                if (this == obj)
                        return true;
                if (obj == null)
                        return false;
                if (getClass() != obj.getClass())
                        return false;
                RecordBean other = (RecordBean) obj;
                if (compString == null) {
                        if (other.compString != null)
                                return false;
                } else if (!compString.equals(other.compString))
                        return false;
                if (keyString == null) {
                        if (other.keyString != null)
                                return false;
                } else if (!keyString.equals(other.keyString))
                        return false;
                return true;
        }
复制代码

搞定了，这个问题，一会会把问题原因，写出来！

仔细研究了一下代码

简单的说下问题原因
发现问题的原因处在beans[i] = iter.next();
这一句上！
iter.next();相当于c里面的指针，执行一个内存地址，
第一次把beans[0] = next()地址;
第二次把beans[1] = next()地址;

所以beans[0] = beans[1] = next()
所以后面的输出是一样的！
处理办法
通过new 新的数组对象。而不是直接使用 next()指向的对象