Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3524
@shixiaogang Thanks for the fast response!
Can y In the initial design document, you suggest that shared state is only
s
I think what we need is a subclass of `StateHandle` that is a
`SharedStateHandle`. I would suggest that the shared state handle has a method
`String getKey()` (or `Object getKey()`) which gives the unique identifier of
the shared state. The `SharedStateRegistry` internally could use something like
a `Map<String, SharedStateHandleAndRefCount>`. I think that would give us a bit
more flexibility in how we describe "equality of shared state": we don't need
to make sure that the state handles themselves implement `equals()` such that
it meets the semantics of the shared state registry. In the case we have
currently, the `getKey()` method could return the normalized path of the file.
---
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.
---
