Repository: samza Updated Branches: refs/heads/master 6939b8cf9 -> 062ac56d1
SAMZA-1075: fix partitionCount assertion from PR53 nickpan47 here's the fix for the issue you found in PR53 Author: Jacob Maes <jm...@linkedin.com> Reviewers: Yi Pan <nickpa...@gmail.com> Closes #57 from jmakes/samza-1075-2 Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/062ac56d Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/062ac56d Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/062ac56d Branch: refs/heads/master Commit: 062ac56d1169ba4af273d7f92e3d6cb1cc553ca8 Parents: 6939b8c Author: Jacob Maes <jma...@apache.org> Authored: Tue Feb 21 16:49:37 2017 -0800 Committer: Jacob Maes <jm...@linkedin.com> Committed: Tue Feb 21 16:49:37 2017 -0800 ---------------------------------------------------------------------- samza-api/src/main/java/org/apache/samza/system/StreamSpec.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/062ac56d/samza-api/src/main/java/org/apache/samza/system/StreamSpec.java ---------------------------------------------------------------------- diff --git a/samza-api/src/main/java/org/apache/samza/system/StreamSpec.java b/samza-api/src/main/java/org/apache/samza/system/StreamSpec.java index d8a2144..e953d46 100644 --- a/samza-api/src/main/java/org/apache/samza/system/StreamSpec.java +++ b/samza-api/src/main/java/org/apache/samza/system/StreamSpec.java @@ -146,7 +146,7 @@ public class StreamSpec { } if (partitionCount < 1) { - throw new NullPointerException("Parameter 'partitionCount' must not be greater than 0"); + throw new IllegalArgumentException("Parameter 'partitionCount' must be greater than 0"); } this.id = id;
