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/master Commit: a2a726139342c5b510053a0432927a3c5f932666 Parents: 4beb98f Author: Bikas Saha <[email protected]> Authored: Fri May 24 17:17:33 2013 -0700 Committer: Bikas Saha <[email protected]> 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()); } } }
