Hi Stig You are correct. I will start using it once we move to 1.1.2.
Thanks. On Tue, Sep 19, 2017 at 9:08 PM, Stig Rohde Døssing <s...@apache.org> wrote: > Hi Chandan, > > This sounds like https://issues.apache.org/jira/browse/STORM-2541 which > should be fixed in 1.1.2. > > 2017-09-19 14:23 GMT+02:00 chandan singh <cks07...@gmail.com>: > > > Hi > > > > I am not sure if it is an existing bug but ManualParitionNamedSubcription > > fails to initialize the spout because > > listener.onPartitionsAssigned(newAssignment) is never invoked. It > requires > > a simple change which I have done locally. If this has already been > fixed, > > please let me know. > > > > Regards > > Chandan > > >
