Github user sihuazhou commented on a diff in the pull request:
    --- Diff: 
    @@ -61,8 +61,9 @@
         *                 over it keys are not supported.
         * @param state State variable for which existing keys will be returned.
         * @param namespace Namespace for which existing keys will be returned.
    +    * @param namespaceSerializer the serializer for the namespace.
    -   <N> Stream<K> getKeys(String state, N namespace);
    +   <N> Stream<K> getKeys(String state, N namespace, TypeSerializer<N> 
    --- End diff --
    Checked! It is me that misunderstand something. The `getPartitionedState 
confused me, it just reset the `namespace` but not reset the 
`namespaceSerializer` for the `previous` state. Please just ignore me... 
Addressing this.


Reply via email to