Page History

public class JobVertex implements java.io.Serializable {
	// 存这个JobVertex对应的ExecutionJobVertex中发生了预测执行的ExecutionVertexs中最快跑完的ExecutionAttemptID
	private Set<ExecutionAttemptID> fastAttemptIdsWithSpeculative = new HashSet<>();

	// 存这个JobVertex对应的ExecutionJobVertex中发生了预测执行的ExecutionVertex中不是最快跑完的ExecutionAttemptID
	private Set<ExecutionAttemptID> slowAttemptIdsWithSpeculative = new HashSet<>();

	// 存这个JobVertex对应的ExecutionJobVertex中没有发生预测执行，且顺利结束的Execution的ExecutionAttemptID
	private Set<ExecutionAttemptID> finishedAttemptIdsWithoutSpeculative = new HashSet<>();

	// 存这个JobVertex的所有Execution的ExecutionAttemptID，包括发生过异常的
	private Set<ExecutionAttemptID> allAttemptIds = new HashSet<>();
}