3 Replies Latest reply on Aug 23, 2010 8:16 AM by anithakothandapani

    org.infinispan.util.concurrent.TimeoutException: Replication timeout

    anithakothandapani

      Hi

      I am getting org.infinispan.util.concurrent.TimeoutException: Replication timeout after inserting a cache data in table using  JdbcStringBasedCacheStore .

       

      Aug 13, 2010 6:43:06 PM org.infinispan.transaction.lookup.GenericTransactionManagerLookup getTransactionManager
      WARNING: Falling back to DummyTransactionManager from Infinispan
      Aug 13, 2010 6:43:07 PM org.infinispan.remoting.transport.jgroups.JGroupsTransport start
      INFO: Starting JGroups Channel
      Aug 13, 2010 6:43:07 PM org.infinispan.util.logging.AbstractLogImpl info
      INFO: Unable to use any JGroups configuration mechanisms provided in properties {}.  Using default JGroups configuration!
      Aug 13, 2010 6:43:07 PM org.jgroups.logging.JDKLogImpl info
      INFO: JGroups version: 2.9.0.GA
      Aug 13, 2010 6:43:09 PM org.infinispan.util.logging.AbstractLogImpl info
      INFO: Received new cluster view: [SGFNode-51274|9] [SGFNode-51274, SGFNode-2593, SGFNode-13545, SGFNode-63371]
      Aug 13, 2010 6:43:09 PM org.infinispan.util.logging.AbstractLogImpl info
      INFO: Cache local address is SGFNode-63371, physical addresses are [16.181.193.139:3823]
      Aug 13, 2010 6:43:09 PM org.infinispan.factories.AbstractComponentRegistry internalStart
      INFO: Infinispan version: Infinispan 'Starobrno' 4.0.0.FINAL
      Aug 13, 2010 6:43:10 PM com.mchange.v2.log.MLog <clinit>
      INFO: MLog clients using java 1.4+ standard logging.
      Aug 13, 2010 6:43:10 PM com.mchange.v2.c3p0.C3P0Registry banner
      INFO: Initializing c3p0-0.9.1.1 [built 15-March-2007 01:32:31; debug? true; trace: 10]
      Aug 13, 2010 6:43:10 PM com.mchange.v2.c3p0.impl.AbstractPoolBackedDataSource getPoolManager
      INFO: Initializing c3p0 pool... com.mchange.v2.c3p0.ComboPooledDataSource [ acquireIncrement -> 3, acquireRetryAttempts -> 30, acquireRetryDelay -> 1000, autoCommitOnClose -> false, automaticTestTable -> null, breakAfterAcquireFailure -> false, checkoutTimeout -> 0, connectionCustomizerClassName -> null, connectionTesterClassName -> com.mchange.v2.c3p0.impl.DefaultConnectionTester, dataSourceName -> 4mwt578atum1rb1y63qxq|f5d030, debugUnreturnedConnectionStackTraces -> false, description -> null, driverClass -> oracle.jdbc.OracleDriver, factoryClassLocation -> null, forceIgnoreUnresolvedTransactions -> false, identityToken -> 4mwt578atum1rb1y63qxq|f5d030, idleConnectionTestPeriod -> 0, initialPoolSize -> 3, jdbcUrl -> jdbc:oracle:thin:@16.138.175.147:1521:TPFDB, lastAcquisitionFailureDefaultUser -> null, maxAdministrativeTaskTime -> 0, maxConnectionAge -> 0, maxIdleTime -> 0, maxIdleTimeExcessConnections -> 0, maxPoolSize -> 15, maxStatements -> 0, maxStatementsPerConnection -> 0, minPoolSize -> 3, numHelperThreads -> 3, numThreadsAwaitingCheckoutDefaultUser -> 0, preferredTestQuery -> null, properties -> {user=******, password=******}, propertyCycle -> 0, testConnectionOnCheckin -> false, testConnectionOnCheckout -> false, unreturnedConnectionTimeout -> 0, usesTraditionalReflectiveProxies -> false ]
      Aug 13, 2010 6:43:11 PM org.infinispan.util.logging.AbstractLogImpl info
      INFO: Trying to fetch state from SGFNode-51274
      Aug 13, 2010 6:43:11 PM org.infinispan.util.logging.AbstractLogImpl info
      INFO: Successfully retrieved and applied state from SGFNode-51274
      Aug 13, 2010 6:43:11 PM org.infinispan.factories.AbstractComponentRegistry internalStart
      INFO: Infinispan version: Infinispan 'Starobrno' 4.0.0.FINAL
      Aug 13, 2010 6:43:31 PM org.infinispan.interceptors.InvocationContextInterceptor handleAll
      SEVERE: Execution error: 
      org.infinispan.util.concurrent.TimeoutException: Replication timeout for SGFNode-51274
      at org.infinispan.remoting.transport.jgroups.JGroupsTransport.invokeRemotely(JGroupsTransport.java:421)
      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.CacheStoreInterceptor.visitPutKeyValueCommand(CacheStoreInterceptor.java:194)
      at org.infinispan.commands.write.PutKeyValueCommand.acceptVisitor(PutKeyValueCommand.java:76)
      at org.infinispan.interceptors.base.CommandInterceptor.invokeNextInterceptor(CommandInterceptor.java:118)
      at org.infinispan.interceptors.CacheLoaderInterceptor.visitPutKeyValueCommand(CacheLoaderInterceptor.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.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:434)
      at org.infinispan.CacheDelegate.put(CacheDelegate.java:205)
      at TestCluster.main(TestCluster.java:14)
      
      
      

       

       

      TestCluster which inserts cache data

      public class TestCluster {
      
           public static void main(String[] args) throws Exception
           {
                CacheManager manager = new DefaultCacheManager("C:/workspace/CacheTest/clusterTest2.xml");
                
                Cache cache = manager.getCache("MyCache");
                
               cache.put("key1", "value1");
                
                
                System.out.println("Cluster details : "+ manager.getClusterName());          
      
                manager.stop();
           }
           
                  
      }
      

       

      infinispan configuration xml.

      <?xml version="1.0" encoding="UTF-8"?>
      <infinispan
            xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
            xsi:schemaLocation="urn:infinispan:config:4.0 http://www.infinispan.org/schemas/infinispan-config-4.0.xsd"
            xmlns="urn:infinispan:config:4.0">
            <global>
      
           <replicationQueueScheduledExecutor factory="org.infinispan.executors.DefaultScheduledExecutorFactory">
               <properties>
                    <property name="threadNamePrefix" value="ReplicationQueueThread"/>
               </properties>
            </replicationQueueScheduledExecutor>
      
            <globalJmxStatistics enabled="true" jmxDomain="infinispan"/>
      
           
            <transport clusterName="Test-cluster" distributedSyncTimeout="50000" nodeName="SGFNode"/>
           
            <serialization marshallerClass="org.infinispan.marshall.VersionAwareMarshaller" version="1.0"/>
      
          
            <shutdown hookBehavior="DEFAULT"/>
         </global>
         <default>
         
          <clustering mode="replication">
      
               <!--
                  Defines whether to retrieve state on startup
               -->
               <stateRetrieval timeout="20000" fetchInMemoryState="false"/>
      
               <!--
                  Network calls are synchronous.
               -->
               <sync replTimeout="20000"/>
               <!--
                  Uncomment this for async replication.
               -->
               <!--<async useReplQueue="true" replQueueInterval="10000" replQueueMaxElements="500"/>-->
            </clustering>
         </default>
      <namedCache name="MyCache">
        <locking isolationLevel="READ_COMMITTED" lockAcquisitionTimeout="150000"/>
            <transaction transactionManagerLookupClass="org.infinispan.transaction.lookup.DummyTransactionManagerLookup"/>
           <clustering mode="replication">
               <stateRetrieval timeout="20000" fetchInMemoryState="true"/>         
               <sync replTimeout="20000"/>        
            </clustering>
            
           <loaders>  
                  <loader class="org.infinispan.loaders.jdbc.stringbased.JdbcStringBasedCacheStore" fetchPersistentState="false" ignoreModifications="false" purgeOnStartup="false">
            <properties>
               <property name="stringsTableNamePrefix" value="ISPN_STRING_TABLE"/>
               <property name="idColumnName" value="ID_COLUMN"/>
               <property name="dataColumnName" value="DATA_COLUMN"/>
               <property name="timestampColumnName" value="TIMESTAMP_COLUMN"/>
               <property name="timestampColumnType" value="NUMBER(19)"/>
               <property name="connectionFactoryClass" value="org.infinispan.loaders.jdbc.connectionfactory.PooledConnectionFactory"/>
               <property name="connectionUrl" value="jdbc:oracle:thin:@myIp:1521:TPFDB"/>
               <property name="userName" value="myuser"/>
                 <property name="password" value="mypassword"/>
               <property name="driverClass" value="oracle.jdbc.OracleDriver"/>
               <property name="idColumnType" value="VARCHAR2(500)"/>
               <property name="dataColumnType" value="BLOB"/>
               <property name="dropTableOnExit" value="true"/>
               <property name="createTableOnStart" value="true"/>
            </properties>
         </loader>
            </loaders> 
       </namedCache>
       
       </infinispan>
      

       

       

      Please help me to understand why this exception is occuring. I am not sure the about the configuration which I used .

       

      regards

      Anitha K