链式mapreduce作业中的计数器

zbdgwd5y  于 2021-05-29  发布在  Hadoop
关注(0)|答案(0)|浏览(196)

我正在使用链式作业。说:

Job 1 -> Job 2 -> Job 3 -> Job 4 -> Job 5

我创建了几个计数器,例如

public static enum MoreEnum {
        counterA,
        counterB;
    }

我正在使用 counterAJob 2 并在Map器和驱动程序中获得正确的输出。甚至在战争开始之前 Job 5 我能得到 counterA 正确地。我在驱动程序中使用这个:
value=job2.getcounters().findcounter(moreenum。countera).getvalue();
然而,在 Job 5 ,当我这样做时: Long value=context.getCounter(MoreEnum.counterA).getValue() ;
我得到的价值是 0 . 为什么会这样以及如何解决这个问题。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题