You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ignite.apache.org by "Semen Boikov (JIRA)" <ji...@apache.org> on 2015/10/01 15:38:26 UTC
[jira] [Commented] (IGNITE-1135) GridPartitionedGetFuture assertion
error
[ https://issues.apache.org/jira/browse/IGNITE-1135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14939826#comment-14939826 ]
Semen Boikov commented on IGNITE-1135:
--------------------------------------
Studied code, see that GridDhtGetFuture.getAsync can return GridCacheEntryInfo with 'null' value since GridCacheMapEntry.info can return not-null GridCacheEntryInfo even if entry value is null. Also if info had not-null value it was sent to requesting node even if skipVals flag was set. Correct fix for these issues:
- fix GridDhtGetFuture.getAsync to always clear GridCacheEntryInfo value if skipVals=true
- when NearGetResponse is handled assert that value was not sent if if skipVals=true
- fix assert in GridCacheContext.addResult to allow null when skipVals=true
> GridPartitionedGetFuture assertion error
> ----------------------------------------
>
> Key: IGNITE-1135
> URL: https://issues.apache.org/jira/browse/IGNITE-1135
> Project: Ignite
> Issue Type: Bug
> Reporter: Andrey Gura
> Assignee: Semen Boikov
> Fix For: ignite-1.5
>
>
> During working on IGNITE-1079 ticket the following problem was found:
> {noformat}
> Failed processing message [senderId=7a07cc81-11e5-42f2-8ffc-184c6c377fc5, msg=GridNearGetResponse [futId=575ef41be41-1a1482a7-e1b9-48c8-9cb7-382fe83792df, miniId=675ef41be41-1a1482a7-e1b9-48c8-9cb7-382fe83792df, ver=GridCacheVersion [topVer=48973890, nodeOrderDrId=3, globalTime=1437493884602, order=1437493880034], entries=[GridCacheEntryInfo [key=KeyCacheObjectImpl [val=7a07cc81-11e5-42f2-8ffc-184c6c377fc5, hasValBytes=true], cacheId=414885281, val=null, ttl=0, expireTime=0, ver=GridCacheVersion [topVer=48973890, nodeOrderDrId=7, globalTime=1437493884824, order=1437493880064], isNew=false, deleted=false]], invalidParts=[], topVer=AffinityTopologyVersion [topVer=7, minorTopVer=0], err=null]]
> java.lang.AssertionError
> at org.apache.ignite.internal.processors.cache.GridCacheContext.addResult(GridCacheContext.java:1811)
> at org.apache.ignite.internal.processors.cache.distributed.dht.GridPartitionedGetFuture.createResultMap(GridPartitionedGetFuture.java:535)
> at org.apache.ignite.internal.processors.cache.distributed.dht.GridPartitionedGetFuture.access$200(GridPartitionedGetFuture.java:45)
> at org.apache.ignite.internal.processors.cache.distributed.dht.GridPartitionedGetFuture$MiniFuture.onResult(GridPartitionedGetFuture.java:715)
> at org.apache.ignite.internal.processors.cache.distributed.dht.GridPartitionedGetFuture.onResult(GridPartitionedGetFuture.java:234)
> at org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.processNearGetResponse(GridDhtAtomicCache.java:2345)
> at org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.access$1000(GridDhtAtomicCache.java:64)
> at org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache$9.apply(GridDhtAtomicCache.java:218)
> at org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache$9.apply(GridDhtAtomicCache.java:216)
> at org.apache.ignite.internal.processors.cache.GridCacheIoManager.processMessage(GridCacheIoManager.java:534)
> at org.apache.ignite.internal.processors.cache.GridCacheIoManager.onMessage0(GridCacheIoManager.java:240)
> at org.apache.ignite.internal.processors.cache.GridCacheIoManager.handleMessage(GridCacheIoManager.java:158)
> at org.apache.ignite.internal.processors.cache.GridCacheIoManager.access$000(GridCacheIoManager.java:48)
> at org.apache.ignite.internal.processors.cache.GridCacheIoManager$1.onMessage(GridCacheIoManager.java:127)
> at org.apache.ignite.internal.managers.communication.GridIoManager.processRegularMessage0(GridIoManager.java:761)
> at org.apache.ignite.internal.managers.communication.GridIoManager.access$1500(GridIoManager.java:59)
> at org.apache.ignite.internal.managers.communication.GridIoManager$5.run(GridIoManager.java:724)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> at java.lang.Thread.run(Thread.java:745)
> {noformat}
> In order to reproduce this need to start IgniteComplexHATest (see https://github.com/agura/vertx-ignite) and run tests several times. Test hangs. Thread dump contains thread that hangs on waiting for future completion:
> {noformat}
> "vert.x-worker-thread-3" #4236 prio=5 os_prio=0 tid=0x00007f47f43c3800 nid=0xc2f waiting on condition [0x00007f475ebe6000]
> java.lang.Thread.State: WAITING (parking)
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000000cee89bc8> (a org.apache.ignite.internal.util.future.GridFutureAdapter$ChainFuture)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:836)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:997)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1304)
> at org.apache.ignite.internal.util.future.GridFutureAdapter.get(GridFutureAdapter.java:115)
> at org.apache.ignite.internal.processors.cache.GridCacheAdapter.containsKey(GridCacheAdapter.java:510)
> at org.apache.ignite.internal.processors.cache.IgniteCacheProxy.containsKey(IgniteCacheProxy.java:869)
> at io.vertx.spi.cluster.ignite.impl.MapImpl.containsKey(MapImpl.java:63)
> at io.vertx.core.impl.HAManager.checkQuorumWhenAdded(HAManager.java:287)
> - locked <0x00000000c3f295d0> (a io.vertx.core.impl.HAManager)
> at io.vertx.core.impl.HAManager.nodeAdded(HAManager.java:253)
> - locked <0x00000000c3f295d0> (a io.vertx.core.impl.HAManager)
> at io.vertx.core.impl.HAManager.access$000(HAManager.java:96)
> at io.vertx.core.impl.HAManager$1.nodeAdded(HAManager.java:139)
> at io.vertx.spi.cluster.ignite.IgniteClusterManager.lambda$null$4(IgniteClusterManager.java:221)
> at io.vertx.spi.cluster.ignite.IgniteClusterManager$$Lambda$54/05230435.handle(Unknown Source)
> at io.vertx.core.impl.ContextImpl.lambda$executeBlocking$18(ContextImpl.java:279)
> at io.vertx.core.impl.ContextImpl$$Lambda$20/445157774.run(Unknown Source)
> at io.vertx.core.impl.OrderedExecutorFactory$OrderedExecutor.lambda$new$101(OrderedExecutorFactory.java:91)
> at io.vertx.core.impl.OrderedExecutorFactory$OrderedExecutor$$Lambda$16/061804750.run(Unknown Source)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> at java.lang.Thread.run(Thread.java:745)
> {noformat}
> This thread also hold lock and blocks other threads waiting on this lock. Similar hangs are possible for other cache opeartions (e.g. get, getAndPut)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)