Details
-
Bug
-
Status: To Do
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
Description
It appears if (for any reason) an empty List is returned in parser sub-classes (any sub-class of BasicParser) the corresponding tuple won't be committed. Hence, Storm retries it based on the retry strategy which won't be required for this situation. Also, if we hit the "spout.maxUncommittedOffsets" parser topology stalls and it needs to be restarted!
This issue can be reproduced by using a very small value for "spout.maxUncommittedOffsets".