I notice that vertex will be killed when any task is failed, but won't been
killed when task is killed (TaskCompletedTransition in VertexImpl)
Is it for the task that is killed when parallelism of vertex is changed ? The
logic here cause the completedTaskCount may be greater than succeededTaskCount.
But looking at the code of VertexImpl.checkVertexForCompletion, vertex should
succeed only when completedTaskCount is equal to succeededTaskCount.
if (vertex.completedTaskCount == vertex.tasks.size()) {
//Only succeed if tasks complete successfully and no terminationCause is
registered.
if(vertex.succeededTaskCount == vertex.tasks.size() &&
vertex.terminationCause == null) {
Best Regard,
Jeff Zhang
