0 Replies Latest reply on Mar 4, 2015 3:43 PM by Lakshmanan Ramakrishnan

    Initial cache load

    Lakshmanan Ramakrishnan Newbie

      Hi 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