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 user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5751
@kl0u Got it! Addressing ...
---
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 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 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 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 user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5751
@kl0u Got it! Addressing...
---
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 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 user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5751
CC: @aljoscha @StefanRRichter
---
10 matches
Mail list logo