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 2013/09/16 22:23:47 UTC
git commit: TEZ-448. Fix serialization error in TezEvent. (hitesh)
Updated Branches:
refs/heads/TEZ-398 f6680dc2c -> 7df571a4e
TEZ-448. Fix serialization error in TezEvent. (hitesh)
Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/7df571a4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/7df571a4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/7df571a4
Branch: refs/heads/TEZ-398
Commit: 7df571a4ef1fdcb85b6711dccfd2fd154e9d7fff
Parents: f6680dc
Author: Hitesh Shah <hi...@apache.org>
Authored: Mon Sep 16 13:23:22 2013 -0700
Committer: Hitesh Shah <hi...@apache.org>
Committed: Mon Sep 16 13:23:22 2013 -0700
----------------------------------------------------------------------
.../src/main/java/org/apache/tez/engine/newapi/impl/TezEvent.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/7df571a4/tez-engine/src/main/java/org/apache/tez/engine/newapi/impl/TezEvent.java
----------------------------------------------------------------------
diff --git a/tez-engine/src/main/java/org/apache/tez/engine/newapi/impl/TezEvent.java b/tez-engine/src/main/java/org/apache/tez/engine/newapi/impl/TezEvent.java
index 02e6112..0f65750 100644
--- a/tez-engine/src/main/java/org/apache/tez/engine/newapi/impl/TezEvent.java
+++ b/tez-engine/src/main/java/org/apache/tez/engine/newapi/impl/TezEvent.java
@@ -107,6 +107,7 @@ public class TezEvent implements Writable {
return;
}
out.writeBoolean(true);
+ out.writeInt(eventType.ordinal());
if (eventType.equals(EventType.TASK_STATUS_UPDATE_EVENT)) {
// TODO NEWTEZ convert to PB
TaskStatusUpdateEvent sEvt = (TaskStatusUpdateEvent) event;
@@ -154,7 +155,6 @@ public class TezEvent implements Writable {
throw new TezUncheckedException("Unknown TezEvent"
+ ", type=" + eventType);
}
- out.writeInt(eventType.ordinal());
out.writeInt(eventBytes.length);
out.write(eventBytes);
}