You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by jm...@apache.org on 2017/02/23 19:27:55 UTC
[09/13] samza git commit: SAMZA-1075: fix partitionCount assertion
from PR53
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 <ni...@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/samza-fluent-api-v1
Commit: 062ac56d1169ba4af273d7f92e3d6cb1cc553ca8
Parents: 6939b8c
Author: Jacob Maes <jm...@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;