my MarketData services is splitted into four publishers : who put values in
the same cache.
Maybe Cache does not support concurrency write ?
__
public class CacheConfig<K, V> extends CacheConfiguration<K, V> {
setCacheMode(CacheMode.PARTITIONED);
setGroupName("quotationFeed");
setStoreByValue(false)
.setWriteThrough(false)
.setReadThrough(false)
.setBackups(1)
.setPartitionLossPolicy(READ_ONLY_ALL)
.setWriteSynchronizationMode(PRIMARY_SYNC)
.setRebalanceMode(CacheRebalanceMode.SYNC)
.setRebalanceThrottle(100)
.setRebalanceBatchSize(2* 1024*1024)
.setStatisticsEnabled(true)
.setManagementEnabled(true);
return this;
}
}
__
etPair(BELDER, B.KBC9M6000C)]
2 javax.cache.CacheException: class
org.apache.ignite.IgniteCheckedException: Failed to write to cache (cache is
moved to a read-only state): marketData
3 at
org.apache.ignite.internal.processors.cache.GridCacheUtils.convertToCacheException(GridCacheUtils.java:1337)
4 at
org.apache.ignite.internal.processors.cache.IgniteCacheProxyImpl.cacheException(IgniteCacheProxyImpl.java:1758)
5 at
org.apache.ignite.internal.processors.cache.IgniteCacheProxyImpl.putAll(IgniteCacheProxyImpl.java:1171)
6 at
org.apache.ignite.internal.processors.cache.GatewayProtectedCacheProxy.putAll(GatewayProtectedCacheProxy.java:868)
7 at
com.socgen.folab.applications.qpw.domain.processor.RtMarketDataContainer.dispatchToCache(RtMarketDataContainer.java:243)
8 at
com.socgen.folab.applications.qpw.domain.processor.RtMarketDataContainer$3.run(RtMarketDataContainer.java:179)
9 at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
10 at java.util.concurrent.FutureTask.run(FutureTask.java:266)
11 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
12 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
13 at java.lang.Thread.run(Thread.java:748)
14 Caused by: org.apache.ignite.IgniteCheckedException: Failed to write
to cache (cache is moved to a read-only state): marketData
15 at
org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTopologyFutureAdapter.validateCache(GridDhtTopologyFutureAdapter.java:97)
16 at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateFuture.mapOnTopology(GridNearAtomicUpdateFuture.java:638)
17 at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicAbstractUpdateFuture.map(GridNearAtomicAbstractUpdateFuture.java:248)
18 at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.updateAll0(GridDhtAtomicCache.java:1105)
19 at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.putAll0(GridDhtAtomicCache.java:653)
20 at
org.apache.ignite.internal.processors.cache.GridCacheAdapter.putAll(GridCacheAdapter.java:2932)
21 at
org.apache.ignite.internal.processors.cache.IgniteCacheProxyImpl.putAll(IgniteCacheProxyImpl.java:1168)
22 ... 8 common frames omitted
__
I tried Stream package but i get another issue ( stream close )...
Comment : On service flush these message and the other continue to publish.
any idea ?
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
