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 <[email protected]>: > 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 >
