[
https://issues.apache.org/jira/browse/IGNITE-11670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848816#comment-16848816
]
Amelchev Nikita commented on IGNITE-11670:
------------------------------------------
[~alex_pl], Your changes look good to me.
> Java thin client: Queries are inconsistent in case of failover
> --------------------------------------------------------------
>
> Key: IGNITE-11670
> URL: https://issues.apache.org/jira/browse/IGNITE-11670
> Project: Ignite
> Issue Type: Bug
> Components: thin client
> Affects Versions: 2.7
> Reporter: Aleksey Plekhanov
> Assignee: Aleksey Plekhanov
> Priority: Major
> Time Spent: 20m
> Remaining Estimate: 0h
>
> When a thin client does failover and switches to a new server, open cursors
> become inconsistent and silently returns the wrong result.
> Reproducer:
> {code:java}
> public void testQueryFailover() throws Exception {
> try (LocalIgniteCluster cluster = LocalIgniteCluster.start(1);
> IgniteClient client = Ignition.startClient(new
> ClientConfiguration()
> .setAddresses(cluster.clientAddresses().iterator().next()))
> ) {
> ObjectName mbeanName =
> U.makeMBeanName(Ignition.allGrids().get(0).name(), "Clients",
> ClientListenerProcessor.class.getSimpleName());
> ClientProcessorMXBean mxBean =
> MBeanServerInvocationHandler.newProxyInstance(
> ManagementFactory.getPlatformMBeanServer(), mbeanName,
> ClientProcessorMXBean.class, true);
> ClientCache<Integer, Integer> cache = client.createCache("cache");
> cache.put(0, 0);
> cache.put(1, 1);
> Query<Cache.Entry<Integer, String>> qry = new ScanQuery<Integer,
> String>().setPageSize(1);
> try (QueryCursor<Cache.Entry<Integer, String>> cur =
> cache.query(qry)) {
> int cnt = 0;
> for (Iterator<Cache.Entry<Integer, String>> it =
> cur.iterator(); it.hasNext(); it.next()) {
> cnt++;
> if (cnt == 1)
> mxBean.dropAllConnections();
> }
> assertEquals(2, cnt);
> }
> }
> }
> {code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
