commit | 192779276eda1a3336525a07ae823003172fcc9e | [log] [tgz] |
---|---|---|
author | Komal Desai <98000016+desaikomal@users.noreply.github.com> | Mon Feb 07 15:06:57 2022 -0800 |
committer | GitHub <noreply@github.com> | Mon Feb 07 15:06:57 2022 -0800 |
tree | 8ceed15a2a78c1db35115a43221ed1f963e6fbf6 | |
parent | 3e6dd3ecbfdaf97d245c7317b7e25c9ff8bc83d3 [diff] |
Fixes #1802 - messages intended for instances that are no longer in the cluster (#1951) In MessageGenerationPhase.java, - process() method populates the list of live instances from cache. But while generateMessage() method has the sessionIdMap information, it still goes through partition/resource/instance map without checking if instance is still part of the cluster or not. It is possible that cache has stale entry but that logic needs to be worked separately. But while generating message, we should check if the instance is still there. So this is a simple change. We need to still look further if cache is getting invalidated properly. To make sure that the cache properly is handled/refreshed under instance being replaced or deletion - have filled another bug: #1956
Helix is part of the Apache Software Foundation.
Project page: http://helix.apache.org/
Mailing list: http://helix.apache.org/mail-lists.html
mvn clean install -Dmaven.test.skip.exec=true
Helix is a generic cluster management framework used for automatic management of partitioned, replicated and distributed resources hosted on a cluster of nodes. Helix provides the following features: