Github user arunmahadevan commented on the issue:
https://github.com/apache/storm/pull/2218
After some more tests (with Caffeine for caching) I found some instances
where the current partition (where entries are added or being removed) could
get evicted causing issues in serialization. So I added a simple caching with
support for pinning that evicts the latest un-pinned partition and based on
tests found it to be better and fits the current use case well. @HeartSaVioR ,
you may want to re-visit the changes.
@roshannaik , added the high level design notes to the JIRA as well.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
