Repository: tez Updated Branches: refs/heads/master 7c16b10e2 -> aa6a84c2c
TEZ-2474. The old taskNum is logged incorrectly when parallelism is changed (zjffdu) Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/aa6a84c2 Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/aa6a84c2 Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/aa6a84c2 Branch: refs/heads/master Commit: aa6a84c2ca2ca4c18029c64451752d8b11e53d28 Parents: 7c16b10 Author: Jeff Zhang <[email protected]> Authored: Thu May 21 16:35:51 2015 +0800 Committer: Jeff Zhang <[email protected]> Committed: Thu May 21 16:35:51 2015 +0800 ---------------------------------------------------------------------- CHANGES.txt | 1 + .../src/main/java/org/apache/tez/dag/app/dag/impl/VertexImpl.java | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/aa6a84c2/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index d1070f8..0f248b9 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -24,6 +24,7 @@ Release 0.7.1: Unreleased INCOMPATIBLE CHANGES ALL CHANGES: + TEZ-2474. The old taskNum is logged incorrectly when parallelism is changed TEZ-2460. Temporary solution for issue due to YARN-2560 TEZ-2455. Tez UI: Dag view caching, error handling and minor layout changes TEZ-2453. Tez UI: show the dagInfo is the application has set the same. http://git-wip-us.apache.org/repos/asf/tez/blob/aa6a84c2/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexImpl.java ---------------------------------------------------------------------- diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexImpl.java b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexImpl.java index 80a0358..e20ee6e 100644 --- a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexImpl.java +++ b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexImpl.java @@ -1710,7 +1710,7 @@ public class VertexImpl implements org.apache.tez.dag.app.dag.Vertex, EventHandl // set new vertex location hints setVertexLocationHint(vertexLocationHint); LOG.info("Vertex " + getLogIdentifier() + " parallelism set to " + parallelism + " from " - + numTasks); + + oldNumTasks); // notify listeners stateChangeNotifier.stateChanged(vertexId,
