You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2016/02/11 16:34:13 UTC
[2/4] storm git commit: STORM-1533: IntegerValidator for metric
consumer parallelism hint
STORM-1533: IntegerValidator for metric consumer parallelism hint
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/8fe6cf7d
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/8fe6cf7d
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/8fe6cf7d
Branch: refs/heads/master
Commit: 8fe6cf7dfbdaaae84e1272af0d4cf9292138da9e
Parents: f8ee7b8
Author: Abhishek Agarwal <ab...@inmobi.com>
Authored: Tue Feb 9 21:23:51 2016 +0530
Committer: Abhishek Agarwal <ab...@inmobi.com>
Committed: Tue Feb 9 21:23:51 2016 +0530
----------------------------------------------------------------------
.../src/jvm/org/apache/storm/validation/ConfigValidation.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/8fe6cf7d/storm-core/src/jvm/org/apache/storm/validation/ConfigValidation.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/validation/ConfigValidation.java b/storm-core/src/jvm/org/apache/storm/validation/ConfigValidation.java
index 4ec5ffd..edff5cf 100644
--- a/storm-core/src/jvm/org/apache/storm/validation/ConfigValidation.java
+++ b/storm-core/src/jvm/org/apache/storm/validation/ConfigValidation.java
@@ -473,7 +473,7 @@ public class ConfigValidation {
}
SimpleTypeValidator.validateField(name, String.class, ((Map) o).get("class"));
- SimpleTypeValidator.validateField(name, Long.class, ((Map) o).get("parallelism.hint"));
+ new IntegerValidator().validateField(name, ((Map) o).get("parallelism.hint"));
}
}