[ 
https://issues.apache.org/jira/browse/IGNITE-21266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Mikhail Petrov updated IGNITE-21266:
------------------------------------
    Fix Version/s: 2.17

> [Java Thin Client] Partition Awareness does not work after cluster restart
> --------------------------------------------------------------------------
>
>                 Key: IGNITE-21266
>                 URL: https://issues.apache.org/jira/browse/IGNITE-21266
>             Project: Ignite
>          Issue Type: Bug
>            Reporter: Mikhail Petrov
>            Assignee: Mikhail Petrov
>            Priority: Major
>              Labels: ise
>             Fix For: 2.17
>
>          Time Spent: 20m
>  Remaining Estimate: 0h
>
> ClientCacheAffinityContext is susceptible to the similar problem that 
> described in 
> [IGNITE-21001|https://issues.apache.org/jira/browse/IGNITE-21001]. As a 
> result cache affinity data required for PA work is not updated after cluster 
> restart.
> Reproducer: 
> {code:java}
> /** */
> public class PartitionAwarenessClusterRestartTest extends 
> ThinClientAbstractPartitionAwarenessTest {
>     /** */
>     @Test
>     public void testGroupNodesAfterClusterRestart() throws Exception {
>         prepareCluster();
>         initClient(getClientConfiguration(0), 0, 1);
>         checkPartitionAwareness();
>         stopAllGrids();
>         prepareCluster();
>         checkPartitionAwareness();
>     }
>     /** */
>     private void checkPartitionAwareness() throws Exception {
>         ClientCache<Object, Object> cache = client.cache(DEFAULT_CACHE_NAME);
>         cache.put(0, 0);
>         opsQueue.clear();
>         for (int i = 1; i < 1000; i++) {
>             cache.put(i, i);
>             
> assertOpOnChannel(nodeChannel(grid(0).affinity(DEFAULT_CACHE_NAME).mapKeyToNode(i).id()),
>  ClientOperation.CACHE_PUT);
>         }
>     }
>     /** */
>     private void prepareCluster() throws Exception {
>         startGrids(3);
>         grid(0).createCache(new CacheConfiguration<>(DEFAULT_CACHE_NAME));
>     }
> }
> {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to