8 Replies Latest reply on Jul 1, 2010 6:36 AM by Mircea Markus

    RejectedExecutionException on cache put()

    craig bomba Novice

      I am getting the below RejectedExecutionException while doing a put() into the cache under heavy put() conditions.  I am concluding this is related to Queue policies on the ThreadPoolExecutor being used.  Wondering if someone can direct me to a (hopeful) configuration setting where I can influence this.  I did see some settings in my jgroups xml file (properties starting with thread_pool), but I have not yet been able to find a setting that will influence this exception from occurring.  In fact, kill -3's don't seem to indicate I am influencing it much at all.

       

      I would appreciate it if someone can point me to some good doc on these settings.  My cache is replicated and I am using Infinispan 4.1BETA1

       

      Thank you.

       

       

      java.util.concurrent.RejectedExecutionException
              at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:1759)
              at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:767)
              at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:658)
              at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:92)
              at org.infinispan.remoting.transport.jgroups.CommandAwareRpcDispatcher.invokeRemoteCommands(CommandAwareRpcDispatcher.java:117)
              at org.infinispan.remoting.transport.jgroups.JGroupsTransport.invokeRemotely(JGroupsTransport.java:402)
              at org.infinispan.remoting.rpc.RpcManagerImpl.invokeRemotely(RpcManagerImpl.java:100)
              at org.infinispan.remoting.rpc.RpcManagerImpl.invokeRemotely(RpcManagerImpl.java:124)
              at org.infinispan.remoting.rpc.RpcManagerImpl.invokeRemotely(RpcManagerImpl.java:229)
              at org.infinispan.remoting.rpc.RpcManagerImpl.invokeRemotely(RpcManagerImpl.java:216)
              at org.infinispan.remoting.rpc.RpcManagerImpl.broadcastRpcCommand(RpcManagerImpl.java:199)
              at org.infinispan.remoting.rpc.RpcManagerImpl.broadcastRpcCommand(RpcManagerImpl.java:192)
              at org.infinispan.interceptors.ReplicationInterceptor.handleCrudMethod(ReplicationInterceptor.java:114)
              at org.infinispan.interceptors.ReplicationInterceptor.visitPutKeyValueCommand(ReplicationInterceptor.java:78)
              at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:76)
              at org.infinispan.interceptors.base.CommandInterceptor.invokeNextInterceptor(CommandInterceptor.java:118)
              at org.infinispan.interceptors.LockingInterceptor.visitPutKeyValueCommand(LockingInterceptor.java:198)
              at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:76)
              at org.infinispan.interceptors.base.CommandInterceptor.invokeNextInterceptor(CommandInterceptor.java:118)
              at org.infinispan.interceptors.base.CommandInterceptor.handleDefault(CommandInterceptor.java:132)
              at org.infinispan.commands.AbstractVisitor.visitPutKeyValueCommand(AbstractVisitor.java:57)
              at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:76)
              at org.infinispan.interceptors.base.CommandInterceptor.invokeNextInterceptor(CommandInterceptor.java:118)
              at org.infinispan.interceptors.TxInterceptor.enlistWriteAndInvokeNext(TxInterceptor.java:183)
              at org.infinispan.interceptors.TxInterceptor.visitPutKeyValueCommand(TxInterceptor.java:132)
              at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:76)
              at org.infinispan.interceptors.base.CommandInterceptor.invokeNextInterceptor(CommandInterceptor.java:118)
              at org.infinispan.interceptors.InvocationContextInterceptor.handleAll(InvocationContextInterceptor.java:48)
              at org.infinispan.interceptors.InvocationContextInterceptor.handleDefault(InvocationContextInterceptor.java:34)
              at org.infinispan.commands.AbstractVisitor.visitPutKeyValueCommand(AbstractVisitor.java:57)
              at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:76)
              at org.infinispan.interceptors.InterceptorChain.invoke(InterceptorChain.java:269)
              at org.infinispan.CacheDelegate.put(CacheDelegate.java:413)
              at org.infinispan.CacheSupport.put(CacheSupport.java:30)
              at com.cboe.infinispan.MyInfinispanLooper.putEntry(MyInfinispanLooper.java:217)
              at com.cboe.infinispan.MyInfinispanLooper.main(MyInfinispanLooper.java:101)