Repository: tez Updated Branches: refs/heads/branch-0.7 7f272ecde -> d5c5b7177
TEZ-2474. The old taskNum is logged incorrectly when parallelism is changed (zjffdu) (cherry picked from commit aa6a84c2ca2ca4c18029c64451752d8b11e53d28) Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/d5c5b717 Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/d5c5b717 Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/d5c5b717 Branch: refs/heads/branch-0.7 Commit: d5c5b7177e741222dca35b1313c2ea8ed231d82b Parents: 7f272ec Author: Jeff Zhang <[email protected]> Authored: Thu May 21 16:35:51 2015 +0800 Committer: Jeff Zhang <[email protected]> Committed: Thu May 21 16:36:35 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/d5c5b717/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index 823d940..d847608 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -7,6 +7,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/d5c5b717/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,
