You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2015/10/24 03:30:48 UTC
[3/5] storm git commit: addressing comments
addressing comments
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/2b3e8617
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/2b3e8617
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/2b3e8617
Branch: refs/heads/master
Commit: 2b3e8617b88779c20524d87fe4d546ba59cc888f
Parents: b57c830
Author: Boyang Jerry Peng <je...@yahoo-inc.com>
Authored: Fri Oct 23 17:09:24 2015 -0500
Committer: Boyang Jerry Peng <je...@yahoo-inc.com>
Committed: Fri Oct 23 17:10:09 2015 -0500
----------------------------------------------------------------------
.../src/jvm/backtype/storm/validation/ConfigValidation.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/2b3e8617/storm-core/src/jvm/backtype/storm/validation/ConfigValidation.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/validation/ConfigValidation.java b/storm-core/src/jvm/backtype/storm/validation/ConfigValidation.java
index 406362f..1b0cd7f 100644
--- a/storm-core/src/jvm/backtype/storm/validation/ConfigValidation.java
+++ b/storm-core/src/jvm/backtype/storm/validation/ConfigValidation.java
@@ -401,7 +401,7 @@ public class ConfigValidation {
}
}
for (Class vv : valueValidators) {
- Object valueValidator = vv.getConstructor().newInstance();;
+ Object valueValidator = vv.getConstructor().newInstance();
if (valueValidator instanceof Validator) {
((Validator) valueValidator).validateField(name + " Map value", entry.getValue());
} else {
@@ -463,7 +463,7 @@ public class ConfigValidation {
throw new IllegalAccessException("Field " + name + " must have map entry with key: class");
}
if(!((Map) o).containsKey("parallelism.hint") ) {
- throw new IllegalAccessException("Field " + name + " must have map entry with key: class");
+ throw new IllegalAccessException("Field " + name + " must have map entry with key: parallelism.hint");
}
SimpleTypeValidator.validateField(name, String.class, ((Map) o).get("class"));