Github user srdo commented on a diff in the pull request:
https://github.com/apache/storm/pull/2314#discussion_r139814647
--- Diff:
storm-client/src/jvm/org/apache/storm/topology/base/BaseWindowedBolt.java ---
@@ -339,6 +364,9 @@ public BaseWindowedBolt withLag(Duration duration) {
* @param interval the interval at which watermark events are generated
*/
public BaseWindowedBolt withWatermarkInterval(Duration interval) {
+ if (interval == null) {
+ throw new IllegalArgumentException("watermark interval cannot
be set null");
--- End diff --
Nit: First letter is lowercase
---
