[GitHub] flink issue #5751: [FLINK-9060][state] Deleting state using KeyedStateBacken...

2018-03-27 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5751 Hi @kl0u ! I have changed the code, could you please have a look when you have time? ---

[GitHub] flink issue #5751: [FLINK-9060][state] Deleting state using KeyedStateBacken...

2018-03-27 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5751 @kl0u Got it! Addressing ... ---

[GitHub] flink issue #5751: [FLINK-9060][state] Deleting state using KeyedStateBacken...

2018-03-27 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/5751 Hi @sihuazhou ! I think that for now materializing the list of keys and then passing it to the `process` is the best solution. But keep in mind that this is only for the `HeapKeyedStateBackend` and not

[GitHub] flink issue #5751: [FLINK-9060][state] Deleting state using KeyedStateBacken...

2018-03-26 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5751 Hi @kl0u , do you have any idea now? Or we can just buffer the keys in to a `list` in `applyToAllKeys()`, I think it also seems not like a bad choice. :) ---

[GitHub] flink issue #5751: [FLINK-9060][state] Deleting state using KeyedStateBacken...

2018-03-25 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/5751 Hi @sihuazhou . I see what you are saying. Let me think about it and I will get back to you probably tomorrow. ---

[GitHub] flink issue #5751: [FLINK-9060][state] Deleting state using KeyedStateBacken...

2018-03-25 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5751 Hi @kl0u , I have changed the code to meet the comments on JIRA, but unfortunately, I found some case that could make the situation a bit complex with that architecture, that is maybe the

[GitHub] flink issue #5751: [FLINK-9060][state] Deleting state using KeyedStateBacken...

2018-03-24 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5751 @kl0u Got it! Addressing... ---

[GitHub] flink issue #5751: [FLINK-9060][state] Deleting state using KeyedStateBacken...

2018-03-23 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5751 Hi @kl0u I changed a bit of the implementation of JIRA, instead of implement multi wrapper classes for different `State`, I introduce a `StateInvocationHandler` which implemented

[GitHub] flink issue #5751: [FLINK-9060][state] Deleting state using KeyedStateBacken...

2018-03-23 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/5751 There is a discussion on the architecture of the solution in the corresponding JIRA https://issues.apache.org/jira/browse/FLINK-9060 ---

[GitHub] flink issue #5751: [FLINK-9060][state] Deleting state using KeyedStateBacken...

2018-03-22 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5751 CC: @aljoscha @StefanRRichter ---