taskstatus类有一个getphase()方法它返回什么?(它们只是map、shuffle、sort、reduce吗?)

xdnvmnnf  于 2021-06-01  发布在  Hadoop
关注(0)|答案(1)|浏览(315)
TaskStatus k = null;
TaskStatus.Phase CurrentPhase = k.getPhase();

如果我想知道一个任务的当前阶段,上面的代码是真的吗?

wgx48brx

wgx48brx1#

根据这个 TaskPhase.getPhase 可以返回以下任意值,具体取决于进程当前处于哪个阶段

public static enum Phase{STARTING, MAP, SHUFFLE, SORT, REDUCE, CLEANUP}

相关问题