Initial cache load
rlachu Mar 4, 2015 3:43 PMHi All,
I am a newbie on Infinispan. We are using 6.0.2 in our application. We are using infinispan (with hibernate search) as a embedded transactional cache in our application. Our data is large and hence we didn't want to use initial state transfer to sync the data. We preferred to load it from the db. We are doing the following to load the data
- We have a cache listener which listens for cache created event and triggers a call to get the data from db
- once we have the data we do the following
Cache<Integer, domainmodel> nonIndexedCache = cache.getAdvancedCache().withFlags(Flag.SKIP_INDEXING).withFlags(Flag.CACHE_MODE_LOCAL);
nonIndexedCache.putAll(data);
Search.getSearchManager(titleHoursCache).getMassIndexer().start();
We thought by doing this, the infinispan will not replicate the data loaded as part of the initial load but we found a replication exception in the log file as below. This is the log from d171584-002 (the other node is d171584-001)
2015-03-04 15:22:55,537 DEBUG MapReduceTask - Invoking MapCombineCommand [keys=[], taskId=12eee6ab-ad1d-49b6-bd5c-b0b5f7a6a337] locally
2015-03-04 15:22:55,541 DEBUG MapReduceTask - Invoking MapCombineCommand [keys=[], taskId=12eee6ab-ad1d-49b6-bd5c-b0b5f7a6a337] on d171584-001-24381
2015-03-04 15:22:55,543 TRACE RpcManagerImpl - d171584-002-49482 invoking in future call MapCombineCommand [keys=[], taskId=12eee6ab-ad1d-49b6-bd5c-b0b5f7a6a337] to recipient list [d171584-001-24381] with options &s
2015-03-04 15:22:55,547 TRACE RpcManagerImpl - d171584-002-49482 invoking MapCombineCommand [keys=[], taskId=12eee6ab-ad1d-49b6-bd5c-b0b5f7a6a337] to recipient list [d171584-001-24381] with options RpcOptions{timeout=15000, unit=MILLISECONDS, fifoOrder=true, totalOrder=false, responseFilter=null, responseMode=SYNCHRONOUS, skipReplicationQueue=false}
2015-03-04 15:22:55,548 DEBUG MapReduceTask - Invoked MapCombineCommand [keys=[], taskId=12eee6ab-ad1d-49b6-bd5c-b0b5f7a6a337] on d171584-001-24381
2015-03-04 15:23:01,592 DEBUG MapReduceTask - Invoked MapCombineCommand [keys=[], taskId=12eee6ab-ad1d-49b6-bd5c-b0b5f7a6a337] locally
2015-03-04 15:23:10,549 TRACE RpcManagerImpl - replication exception:
org.infinispan.util.concurrent.TimeoutException: Node d171584-001-24381 timed out
at org.infinispan.remoting.transport.jgroups.CommandAwareRpcDispatcher.invokeRemoteCommand(CommandAwareRpcDispatcher.java:174)
at org.infinispan.remoting.transport.jgroups.JGroupsTransport.invokeRemotely(JGroupsTransport.java:521)
at org.infinispan.remoting.rpc.RpcManagerImpl.invokeRemotely(RpcManagerImpl.java:281)
at org.infinispan.remoting.rpc.RpcManagerImpl$2.call(RpcManagerImpl.java:315)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: org.jgroups.TimeoutException: timeout sending message to d171584-001-24381
at org.jgroups.blocks.MessageDispatcher.sendMessage(MessageDispatcher.java:419)
at org.infinispan.remoting.transport.jgroups.CommandAwareRpcDispatcher.processSingleCall(CommandAwareRpcDispatcher.java:353)
at org.infinispan.remoting.transport.jgroups.CommandAwareRpcDispatcher.invokeRemoteCommand(CommandAwareRpcDispatcher.java:167)
... 7 more
Please note the keys to send is an empty array...
Are we missing something?
Thanks in advance for any help or pointers
Thanks
Lakshmanan