Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/848#issuecomment-114044907
I think a good addition would be to remember the number of elements in the
set, and use that to validate that the deserialization worked properly.
Serializers may be user-defined (when they want) and the user-defined
serializers may be buggy. Counting the number of elements and verifying that
everything is consumed after deserialization is a good way of figuring out
whether things are sane, and giving an error if not.
---
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 [email protected] or file a JIRA ticket
with INFRA.
---
