You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by hi...@apache.org on 2014/08/13 05:05:45 UTC
[2/2] git commit: TEZ-1404. groupCommitInProgress in
RecoveryTransition of DAGImpl is not set correctly. (Jeff Zhang via hitesh)
TEZ-1404. groupCommitInProgress in RecoveryTransition of DAGImpl is not set correctly. (Jeff Zhang via hitesh)
Project: http://git-wip-us.apache.org/repos/asf/tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/1e48706a
Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/1e48706a
Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/1e48706a
Branch: refs/heads/master
Commit: 1e48706a7dbb3a48fa9721a0f965d80245827ce4
Parents: eec14eb
Author: Hitesh Shah <hi...@apache.org>
Authored: Tue Aug 12 20:04:38 2014 -0700
Committer: Hitesh Shah <hi...@apache.org>
Committed: Tue Aug 12 20:04:38 2014 -0700
----------------------------------------------------------------------
.../src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tez/blob/1e48706a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java
index 80f6aba..df22c50 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java
@@ -1338,8 +1338,9 @@ public class DAGImpl implements org.apache.tez.dag.app.dag.DAG,
if (!entry.getValue().booleanValue()) {
LOG.info("Found a pending Vertex Group commit"
+ ", vertexGroup=" + entry.getKey());
+ groupCommitInProgress = true;
+ break;
}
- groupCommitInProgress = true;
}
}