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.
---
