You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@reef.apache.org by bg...@apache.org on 2014/12/17 18:14:23 UTC
incubator-reef git commit: [REEF-74] This adds a more descritive text
to the Exception thrown in EvaluatorControlHandler.
Repository: incubator-reef
Updated Branches:
refs/heads/master 12f7c9d9a -> ec477fd41
[REEF-74] This adds a more descritive text to the Exception thrown in
EvaluatorControlHandler.
JIRA:
[REEF-74] https://issues.apache.org/jira/browse/REEF-74
Pull Request:
Closes #35
Author
Markus Weimer weimer@apache.org
Project: http://git-wip-us.apache.org/repos/asf/incubator-reef/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-reef/commit/ec477fd4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-reef/tree/ec477fd4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-reef/diff/ec477fd4
Branch: refs/heads/master
Commit: ec477fd41663d386c35ec0ea4b97cb438614c47d
Parents: 12f7c9d
Author: Markus Weimer <we...@apache.org>
Authored: Sun Dec 14 13:22:36 2014 -0500
Committer: Byung-Gon Chun <bg...@apache.org>
Committed: Thu Dec 18 02:10:03 2014 +0900
----------------------------------------------------------------------
.../common/driver/evaluator/EvaluatorControlHandler.java | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/ec477fd4/reef-common/src/main/java/org/apache/reef/runtime/common/driver/evaluator/EvaluatorControlHandler.java
----------------------------------------------------------------------
diff --git a/reef-common/src/main/java/org/apache/reef/runtime/common/driver/evaluator/EvaluatorControlHandler.java b/reef-common/src/main/java/org/apache/reef/runtime/common/driver/evaluator/EvaluatorControlHandler.java
index 84be897..ce62027 100644
--- a/reef-common/src/main/java/org/apache/reef/runtime/common/driver/evaluator/EvaluatorControlHandler.java
+++ b/reef-common/src/main/java/org/apache/reef/runtime/common/driver/evaluator/EvaluatorControlHandler.java
@@ -69,7 +69,15 @@ public final class EvaluatorControlHandler {
throw new IllegalStateException("Trying to send an EvaluatorControlProto before the Evaluator ID is set.");
}
if (!this.stateManager.isRunning()) {
- throw new IllegalStateException("Trying to send an EvaluatorControlProto to an Evaluator that isn't running.");
+ final String msg = new StringBuilder()
+ .append("Trying to send an EvaluatorControlProto to Evaluator [")
+ .append(this.evaluatorId)
+ .append("] that is in state [")
+ .append(this.stateManager.toString())
+ .append("], not [RUNNING]. The control message was: ")
+ .append(evaluatorControlProto.toString())
+ .toString();
+ throw new IllegalStateException(msg);
}
this.wrapped.get().onNext(evaluatorControlProto);
}