wenjin272 commented on PR #581: URL: https://github.com/apache/flink-agents/pull/581#issuecomment-4117598925
Thanks for you work @joeyutong, LGTM. Could you take a look at your convenience? In pr #80, it was discussed that keys outside the key range need to be filtered out after rescaling. However, it appears that it was not implemented at the time. > I suggest replacing currentProcessingKeysOpState to UnionList. This change would ensure that all keys are retained even after a parallelism modification or restart. After that, we can simply iterate through the list and clean up any keys that fall outside the current key range. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
