[
https://issues.apache.org/jira/browse/IGNITE-4103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15663240#comment-15663240
]
Anton Vinogradov edited comment on IGNITE-4103 at 11/15/16 8:19 AM:
--------------------------------------------------------------------
Val, Saikat
This fixed as a part of IGNITE-500
Now
{noformat}s.addData(1, 1);{noformat}
will produce
{noformat}
java.lang.IllegalStateException: Data streamer has been closed.
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.enterBusy(DataStreamerImpl.java:406)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.addDataInternal(DataStreamerImpl.java:613)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.addData(DataStreamerImpl.java:667)
at org.apache.ignite.cache.StreamerTest.main(StreamerTest.java:60)
{noformat}
once data send failure detected.
Streamer.close() will fail with
{noformat}
javax.cache.CacheException: class org.apache.ignite.IgniteCheckedException:
Data streamer has been cancelled: DataStreamerImpl
[rcvr=org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$IsolatedUpdater@2c5529ab,
ioPlcRslvr=org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$DefaultIoPolicyResolver@58791700,
cacheName=test, bufSize=1024, parallelOps=16, timeout=-1, autoFlushFreq=0,
bufMappings={58aa151c-e8a8-42de-aafa-3f64026bebdb=Buffer [node=TcpDiscoveryNode
[id=58aa151c-e8a8-42de-aafa-3f64026bebdb, addrs=[0:0:0:0:0:0:0:1, 127.0.0.1,
172.25.4.58], sockAddrs=[/0:0:0:0:0:0:0:1:47500, /127.0.0.1:47500,
/172.25.4.58:47500], discPort=47500, order=1, intOrder=1,
lastExchangeTime=1479114691463, loc=false, ver=1.7.0#19700101-sha1:00000000,
isClient=false], isLocNode=false, idGen=3350,
sem=java.util.concurrent.Semaphore@52817c70[Permits = 16],
batchTopVer=AffinityTopologyVersion [topVer=3, minorTopVer=2], entriesCnt=0,
locFutsSize=0, reqsSize=0]}, cacheObjProc=GridProcessorAdapter [],
cacheObjCtx=org.apache.ignite.internal.processors.cache.binary.CacheObjectBinaryContext@1783e844,
cancelled=true, failCntr=80, activeFuts=[GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696787, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696787,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT]], jobPda=null, depCls=null,
fut=DataStreamerFuture [super=GridFutureAdapter [resFlag=0, res=null,
startTime=1479114691795, endTime=0, ignoreInterrupts=false, state=INIT]],
publicFut=IgniteFuture [orig=DataStreamerFuture [super=GridFutureAdapter
[resFlag=0, res=null, startTime=1479114691795, endTime=0,
ignoreInterrupts=false, state=INIT]]], disconnectErr=null, closed=true,
lastFlushTime=1479114696807, skipStore=false, keepBinary=false, maxRemapCnt=32,
remapSem=java.util.concurrent.Semaphore@265e9b3c[Permits = 2147483647],
remapOwning=false]
at
org.apache.ignite.internal.processors.cache.GridCacheUtils.convertToCacheException(GridCacheUtils.java:1440)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.close(DataStreamerImpl.java:1160)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.close(DataStreamerImpl.java:1244)
at org.apache.ignite.cache.StreamerTest.main(StreamerTest.java:73)
Caused by: class org.apache.ignite.IgniteCheckedException: Data streamer has
been cancelled: DataStreamerImpl
[rcvr=org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$IsolatedUpdater@2c5529ab,
ioPlcRslvr=org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$DefaultIoPolicyResolver@58791700,
cacheName=test, bufSize=1024, parallelOps=16, timeout=-1, autoFlushFreq=0,
bufMappings={58aa151c-e8a8-42de-aafa-3f64026bebdb=Buffer [node=TcpDiscoveryNode
[id=58aa151c-e8a8-42de-aafa-3f64026bebdb, addrs=[0:0:0:0:0:0:0:1, 127.0.0.1,
172.25.4.58], sockAddrs=[/0:0:0:0:0:0:0:1:47500, /127.0.0.1:47500,
/172.25.4.58:47500], discPort=47500, order=1, intOrder=1,
lastExchangeTime=1479114691463, loc=false, ver=1.7.0#19700101-sha1:00000000,
isClient=false], isLocNode=false, idGen=3350,
sem=java.util.concurrent.Semaphore@52817c70[Permits = 16],
batchTopVer=AffinityTopologyVersion [topVer=3, minorTopVer=2], entriesCnt=0,
locFutsSize=0, reqsSize=0]}, cacheObjProc=GridProcessorAdapter [],
cacheObjCtx=org.apache.ignite.internal.processors.cache.binary.CacheObjectBinaryContext@1783e844,
cancelled=true, failCntr=80, activeFuts=[GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696787, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696787,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT]], jobPda=null, depCls=null,
fut=DataStreamerFuture [super=GridFutureAdapter [resFlag=0, res=null,
startTime=1479114691795, endTime=0, ignoreInterrupts=false, state=INIT]],
publicFut=IgniteFuture [orig=DataStreamerFuture [super=GridFutureAdapter
[resFlag=0, res=null, startTime=1479114691795, endTime=0,
ignoreInterrupts=false, state=INIT]]], disconnectErr=null, closed=true,
lastFlushTime=1479114696807, skipStore=false, keepBinary=false, maxRemapCnt=32,
remapSem=java.util.concurrent.Semaphore@265e9b3c[Permits = 2147483647],
remapOwning=false]
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$5.apply(DataStreamerImpl.java:859)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$5.apply(DataStreamerImpl.java:828)
at
org.apache.ignite.internal.util.future.GridFutureAdapter$ArrayListener.apply(GridFutureAdapter.java:449)
at
org.apache.ignite.internal.util.future.GridFutureAdapter$ArrayListener.apply(GridFutureAdapter.java:432)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.notifyListener(GridFutureAdapter.java:264)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.notifyListeners(GridFutureAdapter.java:252)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.onDone(GridFutureAdapter.java:382)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.onDone(GridFutureAdapter.java:348)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$Buffer.onResponse(DataStreamerImpl.java:1789)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$3.onMessage(DataStreamerImpl.java:335)
at
org.apache.ignite.internal.managers.communication.GridIoManager.invokeListener(GridIoManager.java:1080)
at
org.apache.ignite.internal.managers.communication.GridIoManager.processRegularMessage0(GridIoManager.java:708)
at
org.apache.ignite.internal.managers.communication.GridIoManager.access$1700(GridIoManager.java:101)
at
org.apache.ignite.internal.managers.communication.GridIoManager$5.run(GridIoManager.java:671)
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)
Caused by: class org.apache.ignite.IgniteCheckedException: DataStreamer request
failed [node=58aa151c-e8a8-42de-aafa-3f64026bebdb]
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$Buffer.onResponse(DataStreamerImpl.java:1778)
... 8 more
Caused by: class org.apache.ignite.IgniteCheckedException: Cache not created or
already destroyed.
at
org.apache.ignite.internal.processors.datastreamer.DataStreamProcessor.localUpdate(DataStreamProcessor.java:320)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamProcessor.processRequest(DataStreamProcessor.java:297)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamProcessor.access$000(DataStreamProcessor.java:56)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamProcessor$1.onMessage(DataStreamProcessor.java:86)
... 7 more
{noformat}
was (Author: avinogradov):
Val, Saikat
This fixes as a part of IGNITE-500
Now
{noformat}s.addData(1, 1);{noformat}
will produce
{noformat}
java.lang.IllegalStateException: Data streamer has been closed.
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.enterBusy(DataStreamerImpl.java:406)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.addDataInternal(DataStreamerImpl.java:613)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.addData(DataStreamerImpl.java:667)
at org.apache.ignite.cache.StreamerTest.main(StreamerTest.java:60)
{noformat}
once data send failure detected.
Streamer.close() will fail with
{noformat}
javax.cache.CacheException: class org.apache.ignite.IgniteCheckedException:
Data streamer has been cancelled: DataStreamerImpl
[rcvr=org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$IsolatedUpdater@2c5529ab,
ioPlcRslvr=org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$DefaultIoPolicyResolver@58791700,
cacheName=test, bufSize=1024, parallelOps=16, timeout=-1, autoFlushFreq=0,
bufMappings={58aa151c-e8a8-42de-aafa-3f64026bebdb=Buffer [node=TcpDiscoveryNode
[id=58aa151c-e8a8-42de-aafa-3f64026bebdb, addrs=[0:0:0:0:0:0:0:1, 127.0.0.1,
172.25.4.58], sockAddrs=[/0:0:0:0:0:0:0:1:47500, /127.0.0.1:47500,
/172.25.4.58:47500], discPort=47500, order=1, intOrder=1,
lastExchangeTime=1479114691463, loc=false, ver=1.7.0#19700101-sha1:00000000,
isClient=false], isLocNode=false, idGen=3350,
sem=java.util.concurrent.Semaphore@52817c70[Permits = 16],
batchTopVer=AffinityTopologyVersion [topVer=3, minorTopVer=2], entriesCnt=0,
locFutsSize=0, reqsSize=0]}, cacheObjProc=GridProcessorAdapter [],
cacheObjCtx=org.apache.ignite.internal.processors.cache.binary.CacheObjectBinaryContext@1783e844,
cancelled=true, failCntr=80, activeFuts=[GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696787, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696787,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT]], jobPda=null, depCls=null,
fut=DataStreamerFuture [super=GridFutureAdapter [resFlag=0, res=null,
startTime=1479114691795, endTime=0, ignoreInterrupts=false, state=INIT]],
publicFut=IgniteFuture [orig=DataStreamerFuture [super=GridFutureAdapter
[resFlag=0, res=null, startTime=1479114691795, endTime=0,
ignoreInterrupts=false, state=INIT]]], disconnectErr=null, closed=true,
lastFlushTime=1479114696807, skipStore=false, keepBinary=false, maxRemapCnt=32,
remapSem=java.util.concurrent.Semaphore@265e9b3c[Permits = 2147483647],
remapOwning=false]
at
org.apache.ignite.internal.processors.cache.GridCacheUtils.convertToCacheException(GridCacheUtils.java:1440)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.close(DataStreamerImpl.java:1160)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.close(DataStreamerImpl.java:1244)
at org.apache.ignite.cache.StreamerTest.main(StreamerTest.java:73)
Caused by: class org.apache.ignite.IgniteCheckedException: Data streamer has
been cancelled: DataStreamerImpl
[rcvr=org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$IsolatedUpdater@2c5529ab,
ioPlcRslvr=org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$DefaultIoPolicyResolver@58791700,
cacheName=test, bufSize=1024, parallelOps=16, timeout=-1, autoFlushFreq=0,
bufMappings={58aa151c-e8a8-42de-aafa-3f64026bebdb=Buffer [node=TcpDiscoveryNode
[id=58aa151c-e8a8-42de-aafa-3f64026bebdb, addrs=[0:0:0:0:0:0:0:1, 127.0.0.1,
172.25.4.58], sockAddrs=[/0:0:0:0:0:0:0:1:47500, /127.0.0.1:47500,
/172.25.4.58:47500], discPort=47500, order=1, intOrder=1,
lastExchangeTime=1479114691463, loc=false, ver=1.7.0#19700101-sha1:00000000,
isClient=false], isLocNode=false, idGen=3350,
sem=java.util.concurrent.Semaphore@52817c70[Permits = 16],
batchTopVer=AffinityTopologyVersion [topVer=3, minorTopVer=2], entriesCnt=0,
locFutsSize=0, reqsSize=0]}, cacheObjProc=GridProcessorAdapter [],
cacheObjCtx=org.apache.ignite.internal.processors.cache.binary.CacheObjectBinaryContext@1783e844,
cancelled=true, failCntr=80, activeFuts=[GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696787, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696787,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT], GridFutureAdapter [resFlag=0,
res=null, startTime=1479114696797, endTime=0, ignoreInterrupts=false,
state=INIT], GridFutureAdapter [resFlag=0, res=null, startTime=1479114696797,
endTime=0, ignoreInterrupts=false, state=INIT]], jobPda=null, depCls=null,
fut=DataStreamerFuture [super=GridFutureAdapter [resFlag=0, res=null,
startTime=1479114691795, endTime=0, ignoreInterrupts=false, state=INIT]],
publicFut=IgniteFuture [orig=DataStreamerFuture [super=GridFutureAdapter
[resFlag=0, res=null, startTime=1479114691795, endTime=0,
ignoreInterrupts=false, state=INIT]]], disconnectErr=null, closed=true,
lastFlushTime=1479114696807, skipStore=false, keepBinary=false, maxRemapCnt=32,
remapSem=java.util.concurrent.Semaphore@265e9b3c[Permits = 2147483647],
remapOwning=false]
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$5.apply(DataStreamerImpl.java:859)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$5.apply(DataStreamerImpl.java:828)
at
org.apache.ignite.internal.util.future.GridFutureAdapter$ArrayListener.apply(GridFutureAdapter.java:449)
at
org.apache.ignite.internal.util.future.GridFutureAdapter$ArrayListener.apply(GridFutureAdapter.java:432)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.notifyListener(GridFutureAdapter.java:264)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.notifyListeners(GridFutureAdapter.java:252)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.onDone(GridFutureAdapter.java:382)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.onDone(GridFutureAdapter.java:348)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$Buffer.onResponse(DataStreamerImpl.java:1789)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$3.onMessage(DataStreamerImpl.java:335)
at
org.apache.ignite.internal.managers.communication.GridIoManager.invokeListener(GridIoManager.java:1080)
at
org.apache.ignite.internal.managers.communication.GridIoManager.processRegularMessage0(GridIoManager.java:708)
at
org.apache.ignite.internal.managers.communication.GridIoManager.access$1700(GridIoManager.java:101)
at
org.apache.ignite.internal.managers.communication.GridIoManager$5.run(GridIoManager.java:671)
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)
Caused by: class org.apache.ignite.IgniteCheckedException: DataStreamer request
failed [node=58aa151c-e8a8-42de-aafa-3f64026bebdb]
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$Buffer.onResponse(DataStreamerImpl.java:1778)
... 8 more
Caused by: class org.apache.ignite.IgniteCheckedException: Cache not created or
already destroyed.
at
org.apache.ignite.internal.processors.datastreamer.DataStreamProcessor.localUpdate(DataStreamProcessor.java:320)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamProcessor.processRequest(DataStreamProcessor.java:297)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamProcessor.access$000(DataStreamProcessor.java:56)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamProcessor$1.onMessage(DataStreamProcessor.java:86)
... 7 more
{noformat}
> IgniteDataStreamer doesn't throw exception if cache is destroyed
> ----------------------------------------------------------------
>
> Key: IGNITE-4103
> URL: https://issues.apache.org/jira/browse/IGNITE-4103
> Project: Ignite
> Issue Type: Bug
> Components: cache
> Affects Versions: 1.7
> Reporter: Valentin Kulichenko
> Assignee: Saikat Maitra
> Fix For: 1.8
>
> Attachments: StreamerTest.java
>
>
> Test reproducing the issue is attached.
> When a streamer streams the data and someone concurrently destroys the cache,
> {{addData}} doesn't throw an exception. Code continues to work and a lot of
> messages like this appear in the log:
> {noformat}
> [12:20:38,451][ERROR][main][CacheObjectBinaryProcessorImpl] Failed to get
> partition
> {noformat}
> The problematic code is in {{IgniteCacheObjectProcessorImpl.partition(...)}}
> method:
> {code}
> try {
> return cctx != null ?
> cctx.affinity().partition(obj, false) :
> ctx.kernalContext().affinity().partition0(ctx.cacheName(), obj, null);
> }
> catch (IgniteCheckedException e) {
> U.error(log, "Failed to get partition");
> return -1;
> }
> {code}
> There are two issues here:
> # Exception is completely ignored, it's not even printed out in {{U.error}}.
> # The exception should be actually rethrown so that streamer can stop adding
> data.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
