It doesn't make any sense to add up offsets. I can see how the current example is flawed (since it just ignores part of the state), but the correct fix is to rework the example such that the state can be aggregated on restore in a meaningful way.
[ Full content available at: https://github.com/apache/flink/pull/6625 ] This message was relayed via gitbox.apache.org for [email protected]
