tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hit...@apache.org
Subject tez git commit: TEZ-1772. Failing tests post TEZ-1737. (Jeff Zhang via hitesh)
Date Thu, 13 Nov 2014 22:13:31 GMT
Repository: tez
Updated Branches:
  refs/heads/master f4c2112f6 -> 1a3059f41


TEZ-1772. Failing tests post TEZ-1737. (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/1a3059f4
Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/1a3059f4
Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/1a3059f4

Branch: refs/heads/master
Commit: 1a3059f41820ce91acc9eeb3b8c30fb4b53ea2b5
Parents: f4c2112
Author: Hitesh Shah <hitesh@apache.org>
Authored: Thu Nov 13 14:12:51 2014 -0800
Committer: Hitesh Shah <hitesh@apache.org>
Committed: Thu Nov 13 14:12:51 2014 -0800

----------------------------------------------------------------------
 CHANGES.txt                                                        | 1 +
 .../org/apache/tez/dag/history/events/VertexFinishedEvent.java     | 2 ++
 tez-dag/src/main/proto/HistoryEvents.proto                         | 1 +
 3 files changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/tez/blob/1a3059f4/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 4f0417e..0f66807 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -26,6 +26,7 @@ ALL CHANGES:
   TEZ-1737. Should add taskNum in VertexFinishedEvent.
   TEZ-1770. Handle ConnectExceptions correctly when establishing connections to an NM which
may be down.
   TEZ-1774. AppLaunched event for Timeline does not have start time set.
+  TEZ-1772. Failing tests post TEZ-1737.
 
 Release 0.5.2: 2014-11-07
 

http://git-wip-us.apache.org/repos/asf/tez/blob/1a3059f4/tez-dag/src/main/java/org/apache/tez/dag/history/events/VertexFinishedEvent.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/history/events/VertexFinishedEvent.java
b/tez-dag/src/main/java/org/apache/tez/dag/history/events/VertexFinishedEvent.java
index d1d7eef..d6e0b79 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/history/events/VertexFinishedEvent.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/history/events/VertexFinishedEvent.java
@@ -98,6 +98,7 @@ public class VertexFinishedEvent implements HistoryEvent, SummaryEvent {
     VertexFinishedProto.Builder builder = VertexFinishedProto.newBuilder();
     builder.setVertexName(vertexName)
         .setVertexId(vertexID.toString())
+        .setNumTasks(numTasks)
         .setState(state.ordinal())
         .setFinishTime(finishTime);
     if (diagnostics != null) {
@@ -109,6 +110,7 @@ public class VertexFinishedEvent implements HistoryEvent, SummaryEvent
{
   public void fromProto(VertexFinishedProto proto) {
     this.vertexName = proto.getVertexName();
     this.vertexID = TezVertexID.fromString(proto.getVertexId());
+    this.numTasks = proto.getNumTasks();
     this.finishTime = proto.getFinishTime();
     this.state = VertexState.values()[proto.getState()];
     if (proto.hasDiagnostics())  {

http://git-wip-us.apache.org/repos/asf/tez/blob/1a3059f4/tez-dag/src/main/proto/HistoryEvents.proto
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/proto/HistoryEvents.proto b/tez-dag/src/main/proto/HistoryEvents.proto
index 5d18b0a..e8f323d 100644
--- a/tez-dag/src/main/proto/HistoryEvents.proto
+++ b/tez-dag/src/main/proto/HistoryEvents.proto
@@ -136,6 +136,7 @@ message VertexFinishedProto {
   optional int64 finish_time = 3;
   optional int32 state = 4;
   optional string diagnostics = 5;
+  optional int32 num_tasks = 6;
 }
 
 message TaskStartedProto {


Mime
View raw message