withTimestampExtractor sliding window

[Raja Mandava]

I am testing Apache Storm 2.2.0 sliding window feature. Configured my
topology as below

tp.setBolt("slidingwindowbolt",
            new rollingbolt()
            .withWindow(new BaseWindowedBolt.Duration(60, TimeUnit.SECONDS),
                        new BaseWindowedBolt.Duration(10, TimeUnit.SECONDS))
            1).shuffleGrouping("kafka_spout", TOPIC_1_STREAM);

When I run this, it works perfectly fine and my bolt executor called at
interval of 10 seconds as configured.

I have modified code to extract timestamp from tuple itself as below

tp.setBolt("slidingwindowbolt",
            new rollingbolt()
            .withWindow(new BaseWindowedBolt.Duration(60, TimeUnit.SECONDS),
                        new BaseWindowedBolt.Duration(10, TimeUnit.SECONDS))
            .withTimestampExtractor(timeExt)
            .withWatermarkInterval(new BaseWindowedBolt.Duration(10,
TimeUnit.SECONDS)),
            1).shuffleGrouping("kafka_spout", TOPIC_1_STREAM);

In this case the bolt is being called only once and after that no more bolt
execute is triggered (Tried with or without setting withWatermarkInterval.

Am I missing something to configure for withTimestampExtractor?


Raja