[jira] [Created] (IGNITE-11237) GetAll may return less data during server node restart

[Anton Vinogradov (Jira)]

Sergey Kozlov created IGNITE-11237:
--------------------------------------

             Summary: GetAll may return less data during server node restart
                 Key: IGNITE-11237
                 URL: https://issues.apache.org/jira/browse/IGNITE-11237
             Project: Ignite
          Issue Type: Bug
    Affects Versions: 2.7
            Reporter: Sergey Kozlov
         Attachments: CachePutAllGetAllExample.java, ExampleNodeStartupRestart.java

0. Use ignite-examples project and Idea

1. Run {{ExampleNodeStartup}}
2. Run {{ExampleNodeStartupRestart}}
3. Run {{CachePutAllGetAllExample}}
Sometimes the received entries number less than expected:
{noformat}
[17:37:25] Ignite node started OK (id=3497ca71)
[17:37:25] Topology snapshot [ver=4, locNode=3497ca71, servers=1, clients=1, state=ACTIVE, CPUs=8, offheap=3.2GB, heap=7.1GB]
Iteration: 10
[17:37:26] Topology snapshot [ver=5, locNode=3497ca71, servers=2, clients=1, state=ACTIVE, CPUs=8, offheap=6.4GB, heap=11.0GB]
Iteration: 20
Iteration: 30
Iteration: 40
Iteration: 50
Iteration: 60
Iteration: 70
Iteration: 80
Iteration: 90
Iteration: 100
Iteration: 110
[17:37:31] Topology snapshot [ver=6, locNode=3497ca71, servers=1, clients=1, state=ACTIVE, CPUs=8, offheap=3.2GB, heap=7.1GB]
[2019-02-06 17:37:31,924][ERROR][main][TcpCommunicationSpi] Failed to send message to remote node [node=TcpDiscoveryNode [id=75d87e82-b466-47c0-8043-d9f7b2c22a60, addrs=[0:0:0:0:0:0:0:1, 127.0.0.1, 172.25.4.52], sockAddrs=[work-pc.gridgain.local/172.25.4.52:47501, /0:0:0:0:0:0:0:1:47501, /127.0.0.1:47501], discPort=47501, order=5, intOrder=4, lastExchangeTime=1549463846635, loc=false, ver=2.7.2#20190205-sha1:43e3211d, isClient=false], msg=GridIoMessage [plc=2, topic=TOPIC_CACHE, topicOrd=8, ordered=false, timeout=0, skipOnTimeout=false, msg=GridNearGetRequest [futId=584ed33c861-8714c669-3f45-45c3-ab40-622a61666c43, miniId=784ed33c861-8714c669-3f45-45c3-ab40-622a61666c43, ver=null, keyMap=null, flags=1, topVer=AffinityTopologyVersion [topVer=5, minorTopVer=1], subjId=3497ca71-1ded-4e60-9396-5a32a0340977, taskNameHash=0, createTtl=-1, accessTtl=-1, mvccSnapshot=null]]]
class org.apache.ignite.internal.cluster.ClusterTopologyCheckedException: Failed to send message (node left topology): TcpDiscoveryNode [id=75d87e82-b466-47c0-8043-d9f7b2c22a60, addrs=[0:0:0:0:0:0:0:1, 127.0.0.1, 172.25.4.52], sockAddrs=[work-pc.gridgain.local/172.25.4.52:47501, /0:0:0:0:0:0:0:1:47501, /127.0.0.1:47501], discPort=47501, order=5, intOrder=4, lastExchangeTime=1549463846635, loc=false, ver=2.7.2#20190205-sha1:43e3211d, isClient=false]
        at org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.createTcpClient(TcpCommunicationSpi.java:3281)
        at org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.createNioClient(TcpCommunicationSpi.java:2992)
        at org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.reserveClient(TcpCommunicationSpi.java:2873)
        at org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.sendMessage0(TcpCommunicationSpi.java:2716)
        at org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.sendMessage(TcpCommunicationSpi.java:2675)
        at org.apache.ignite.internal.managers.communication.GridIoManager.send(GridIoManager.java:1656)
        at org.apache.ignite.internal.managers.communication.GridIoManager.sendToGridTopic(GridIoManager.java:1731)
        at org.apache.ignite.internal.processors.cache.GridCacheIoManager.send(GridCacheIoManager.java:1245)
        at org.apache.ignite.internal.processors.cache.distributed.dht.GridPartitionedGetFuture.map(GridPartitionedGetFuture.java:334)
        at org.apache.ignite.internal.processors.cache.distributed.dht.GridPartitionedGetFuture.initialMap(GridPartitionedGetFuture.java:176)
        at org.apache.ignite.internal.processors.cache.distributed.dht.GridPartitionedGetFuture.init(GridPartitionedGetFuture.java:162)
        at org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.getAllAsync0(GridDhtAtomicCache.java:1640)
        at org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.getAllAsyncInternal(GridDhtAtomicCache.java:589)
        at org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.getAll0(GridDhtAtomicCache.java:498)
        at org.apache.ignite.internal.processors.cache.GridCacheAdapter.getAll(GridCacheAdapter.java:1587)
        at org.apache.ignite.internal.processors.cache.IgniteCacheProxyImpl.getAll(IgniteCacheProxyImpl.java:1130)
        at org.apache.ignite.internal.processors.cache.GatewayProtectedCacheProxy.getAll(GatewayProtectedCacheProxy.java:686)
        at org.apache.ignite.examples.datagrid.CachePutAllGetAllExample.putAllGetAll(CachePutAllGetAllExample.java:94)
        at org.apache.ignite.examples.datagrid.CachePutAllGetAllExample.main(CachePutAllGetAllExample.java:66)
ERROR!!!! GetAll size: 1048
Iteration: 120
Iteration: 130
Iteration: 140
Iteration: 150
Iteration: 160
Iteration: 170
Iteration: 180
Iteration: 190
Iteration: 200

Process finished with exit code 1

{noformat}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)