Github user srdo commented on a diff in the pull request: https://github.com/apache/storm/pull/2314#discussion_r139811727 --- 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("Lag duration cannot be set null"); --- End diff -- This seems like it belongs in the withLag method.
---