ignite-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Semen Boikov (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (IGNITE-1135) GridPartitionedGetFuture assertion error
Date Thu, 01 Oct 2015 13:38:26 GMT

    [ 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)

Mime
View raw message