You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by bi...@apache.org on 2013/05/25 02:20:38 UTC
git commit: TEZ-142. DAG does not throw error when it receives an
unknown DAGSchedulerUpdateEvent (bikas)
Updated Branches:
refs/heads/TEZ-1 4beb98f31 -> a2a726139
TEZ-142. DAG does not throw error when it receives an unknown DAGSchedulerUpdateEvent (bikas)
Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/a2a72613
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/a2a72613
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/a2a72613
Branch: refs/heads/TEZ-1
Commit: a2a726139342c5b510053a0432927a3c5f932666
Parents: 4beb98f
Author: Bikas Saha <bi...@apache.org>
Authored: Fri May 24 17:17:33 2013 -0700
Committer: Bikas Saha <bi...@apache.org>
Committed: Fri May 24 17:17:33 2013 -0700
----------------------------------------------------------------------
.../org/apache/tez/dag/app/dag/impl/DAGImpl.java | 4 +++-
1 files changed, 3 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/a2a72613/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 5f47818..4c63d8f 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
@@ -57,6 +57,7 @@ import org.apache.tez.dag.api.records.DAGProtos.DAGPlan;
import org.apache.tez.dag.api.records.DAGProtos.VertexPlan;
import org.apache.tez.dag.api.EdgeProperty;
import org.apache.tez.dag.api.TezConfiguration;
+import org.apache.tez.dag.api.TezException;
import org.apache.tez.dag.api.VertexLocationHint;
import org.apache.tez.dag.api.client.DAGStatusBuilder;
import org.apache.tez.dag.api.client.ProgressBuilder;
@@ -1177,7 +1178,8 @@ public class DAGImpl implements org.apache.tez.dag.app.dag.DAG,
dag.dagScheduler.scheduleTask(sEvent);
break;
default:
- LOG.warn("Unknown DAGEventSchedulerUpdate:" + sEvent.getUpdateType());
+ throw new TezException("Unknown DAGEventSchedulerUpdate:"
+ + sEvent.getUpdateType());
}
}
}