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)
