Hi Andrey,

Apologies for late reply. I don't have any exact reproduce. I can see this
log frequently in our logs.

attached the ignite.xml.

Thanks.



On 26 April 2017 at 18:32, Andrey Gura <[email protected]> wrote:

> Anil,
>
> what kind of lock do you mean? What are steps for reproduce? What
> version if vert-ignite do use and what is your configuration?
>
> On Wed, Apr 26, 2017 at 2:16 PM, Anil <[email protected]> wrote:
> > HI,
> >
> > I am using vertx-ignite and when node is left the topology, lock is not
> > getting released and whole server is not responding.
> >
> > 2017-04-26 04:09:15 WARN  vertx-blocked-thread-checker
> > BlockedThreadChecker:57 - Thread Thread[vert.x-worker-thread-
> 82,5,ignite]
> > has been blocked for 2329981 ms, time limit is 60000
> > io.vertx.core.VertxException: Thread blocked
> >         at sun.misc.Unsafe.park(Native Method)
> >         at java.util.concurrent.locks.LockSupport.park(LockSupport.
> java:175)
> >         at
> > java.util.concurrent.locks.AbstractQueuedSynchronizer.
> parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:836)
> >         at
> > java.util.concurrent.locks.AbstractQueuedSynchronizer.
> doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:997)
> >         at
> > java.util.concurrent.locks.AbstractQueuedSynchronizer.
> acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1304)
> >         at
> > org.apache.ignite.internal.util.future.GridFutureAdapter.
> get0(GridFutureAdapter.java:161)
> >         at
> > org.apache.ignite.internal.util.future.GridFutureAdapter.
> get(GridFutureAdapter.java:119)
> >         at
> > org.apache.ignite.internal.processors.cache.distributed.
> dht.atomic.GridDhtAtomicCache.get0(GridDhtAtomicCache.java:488)
> >         at
> > org.apache.ignite.internal.processors.cache.GridCacheAdapter.get(
> GridCacheAdapter.java:4663)
> >         at
> > org.apache.ignite.internal.processors.cache.GridCacheAdapter.get(
> GridCacheAdapter.java:1388)
> >         at
> > org.apache.ignite.internal.processors.cache.IgniteCacheProxy.get(
> IgniteCacheProxy.java:1117)
> >         at io.vertx.spi.cluster.ignite.impl.MapImpl.get(MapImpl.java:81)
> >         at io.vertx.core.impl.HAManager.chooseHashedNode(HAManager.
> java:590)
> >         at io.vertx.core.impl.HAManager.checkSubs(HAManager.java:519)
> >         at io.vertx.core.impl.HAManager.nodeLeft(HAManager.java:305)
> >         at io.vertx.core.impl.HAManager.access$100(HAManager.java:107)
> >         at io.vertx.core.impl.HAManager$1.nodeLeft(HAManager.java:157)
> >         at
> > io.vertx.spi.cluster.ignite.IgniteClusterManager.lambda$
> null$4(IgniteClusterManager.java:254)
> >         at
> > io.vertx.spi.cluster.ignite.IgniteClusterManager$$Lambda$
> 36/837728834.handle(Unknown
> > Source)
> >         at
> > io.vertx.core.impl.ContextImpl.lambda$executeBlocking$1(ContextImpl.
> java:271)
> >         at io.vertx.core.impl.ContextImpl$$Lambda$13/
> 116289363.run(Unknown
> > Source)
> >         at io.vertx.core.impl.TaskQueue.lambda$new$0(TaskQueue.java:60)
> >         at io.vertx.core.impl.TaskQueue$$Lambda$12/443290224.run(Unknown
> > Source)
> >         at
> > java.util.concurrent.ThreadPoolExecutor.runWorker(
> ThreadPoolExecutor.java:1142)
> >         at
> > java.util.concurrent.ThreadPoolExecutor$Worker.run(
> ThreadPoolExecutor.java:617)
> >         at java.lang.Thread.run(Thread.java:745)
> >
> > was it a known issue ?
> >
> > Thanks
>
<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans";
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
       xmlns:util="http://www.springframework.org/schema/util";
       xsi:schemaLocation="http://www.springframework.org/schema/beans
                           http://www.springframework.org/schema/beans/spring-beans.xsd
                           http://www.springframework.org/schema/util
                           http://www.springframework.org/schema/util/spring-util.xsd";>
<bean id ="cacheUpdateService" class="net.test.cs.cache.service.CacheUpdateService"/>
  
 	<bean id = "grid1" class="org.apache.ignite.configuration.IgniteConfiguration">		
	<property name="peerClassLoadingEnabled" value="false" />
  <property name="failureDetectionTimeout" value="10000"/>
	<property name="metricsLogFrequency" value="0" />
	
	<property name="swapSpaceSpi">
		<bean class="org.apache.ignite.spi.swapspace.file.FileSwapSpaceSpi">
				<property name="baseDirectory" value="/opt/ignite-manager/api/swap"/>
		</bean>
	</property>

    <!-- Explicitly configure TCP discovery SPI to provide list of initial nodes. -->
    <property name="discoverySpi">
      <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
	 <property name="networkTimeout" value="60000"/>
	 <property name="socketTimeout" value="60000"/>
	 <property name="ackTimeout" value="60000"/>
	 <property name="heartbeatFrequency" value="60000"/>
	 <property name="reconnectCount" value="5"/>

        <property name="ipFinder">
          <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
	  <!-- <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder">
	    <property name="multicastGroup" value="228.10.10.157"/> -->
            <property name="addresses">
              <list>
				<value>X.X.X.1</value>
				<value>X.X.X.2</value>
				<value>X.X.X.3</value>
				<value>X.X.X.4</value>
              </list>
            </property>
          </bean>
        </property>
      </bean>
    </property>
<property name="lifecycleBeans">
	        <list>
	            <ref bean="cacheUpdateService"/>
	        </list>
    	</property>
    	<property name="cacheConfiguration">
    		<list>	
			    <bean class="org.apache.ignite.configuration.CacheConfiguration">
			        <property name="name" value="LOCK_CACHE"/>
			        <property name="cacheMode" value="PARTITIONED"/>
<property name="atomicityMode" value="TRANSACTIONAL"/>
			        <property name="backups" value="0"/>                
			        <property name="swapEnabled" value="true"/>
			        <property name="copyOnRead" value="false"/>
					<property name="memoryMode" value="OFFHEAP_TIERED"/>		 
					<property name="offHeapMaxMemory" value="#{10 * 1024L * 1024L * 1024L}"/>
					<property name="indexedTypes">
					  <list>
						<value>java.lang.String</value>
						<value>net.test.cs.entity.Lock</value>
					  </list>
					</property>
				</bean>
				<bean class="org.apache.ignite.configuration.CacheConfiguration">
			        <property name="name" value="CACHE"/>
			        <property name="cacheMode" value="PARTITIONED"/>
               <property name="atomicityMode" value="TRANSACTIONAL"/>
			        <property name="backups" value="0"/>                
			        <property name="swapEnabled" value="true"/>
			        <property name="copyOnRead" value="false"/>
					<property name="memoryMode" value="OFFHEAP_TIERED"/>		 
					<property name="offHeapMaxMemory" value="#{10 * 1024L * 1024L * 1024L}"/>
					<property name="indexedTypes">
					  <list>
						<value>org.apache.ignite.cache.affinity.AffinityKey</value>
						<value>net.test.cs.entity.Cache</value>
					  </list>
					</property>
				</bean>				
			</list>
		</property>
  </bean>  
</beans>

Reply via email to