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


---

Reply via email to