ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Pothanaboyina <balaj...@techouts.com>
Subject i am tring to load mongo store but i am getting this messege
Date Thu, 25 May 2017 09:40:30 GMT
[14:28:10,334][ERROR][exchange-worker-#29%null%][GridDhtPartitionsExchangeFuture]
Failed to reinitialize local partitions (preloading will be stopped):
GridDhtPartitionExchangeId [topVer=AffinityTopologyVersion [topVer=1,
minorTopVer=1], nodeId=d8a6d5d6, evt=DISCOVERY_CUSTOM_EVT]
class org.apache.ignite.IgniteException: Either transaction manager or data
source is required by CacheSpringStoreSessionListener.
	at
org.apache.ignite.cache.store.spring.CacheSpringStoreSessionListener.start(CacheSpringStoreSessionListener.java:118)
	at
org.apache.ignite.internal.processors.cache.GridCacheUtils.startStoreSessionListeners(GridCacheUtils.java:1527)
	at
org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter.start0(GridCacheStoreManagerAdapter.java:230)
	at
org.apache.ignite.internal.processors.cache.store.CacheOsStoreManager.start0(CacheOsStoreManager.java:64)
	at
org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter.start(GridCacheManagerAdapter.java:50)
	at
org.apache.ignite.internal.processors.cache.GridCacheProcessor.startCache(GridCacheProcessor.java:1243)
	at
org.apache.ignite.internal.processors.cache.GridCacheProcessor.prepareCacheStart(GridCacheProcessor.java:1943)
	at
org.apache.ignite.internal.processors.cache.GridCacheProcessor.prepareCacheStart(GridCacheProcessor.java:1833)
	at
org.apache.ignite.internal.processors.cache.CacheAffinitySharedManager.onCacheChangeRequest(CacheAffinitySharedManager.java:379)
	at
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture.onCacheChangeRequest(GridDhtPartitionsExchangeFuture.java:688)
	at
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture.init(GridDhtPartitionsExchangeFuture.java:529)
	at
org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$ExchangeWorker.body(GridCachePartitionExchangeManager.java:1806)
	at
org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:110)
	at java.lang.Thread.run(Thread.java:745)





	@SuppressWarnings({ "unchecked", "serial" })
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		
		   try (Ignite ignite =
Ignition.start("examples/config/example-ignite.xml")) {
	            System.out.println();
	            System.out.println(">>> Cache store example started.");
	            CacheConfiguration<Long, Employee> cacheCfg = new
CacheConfiguration<>(CACHE_NAME);
	            cacheCfg.setAtomicityMode(TRANSACTIONAL);
	            // Configure Spring store.
	            @SuppressWarnings("unused")
				CacheSpringEmployeeStore store=new CacheSpringEmployeeStore();
	           
cacheCfg.setCacheStoreFactory(FactoryBuilder.factoryOf(CacheSpringEmployeeStore.class));
	            cacheCfg.setReadThrough(true);
	            cacheCfg.setWriteThrough(true);
	            // Configure Spring session listener.
	            cacheCfg.setCacheStoreSessionListenerFactories(new
Factory<CacheStoreSessionListener>() {
	                @Override public CacheStoreSessionListener create() {
	                    CacheSpringStoreSessionListener lsnr = new
CacheSpringStoreSessionListener();

	                   
lsnr.setDataSource(JdbcConnectionPool.create("jdbc:h2:tcp://localhost/mem:ExampleDb",
"sa", ""));
	                  

	                    return lsnr;
	                }
	            });
	            
	            cacheCfg.setReadThrough(true);
	            cacheCfg.setWriteThrough(true);
	            
	            try (IgniteCache<Long, Employee> cache =
ignite.getOrCreateCache(cacheCfg)) {
	                // Make initial cache loading from persistent store. This
is a
	                // distributed operation and will call
CacheStore.loadCache(...)
	                // method on all nodes in topology.
	              //  loadCache(cache);

	                // Start transaction and execute several cache operations
with
	                // read/write-through to persistent store.
	                executeTransaction(cache);
	                Employee val = cache.get(id);

	                System.out.println("Read value: " + val.getName());
	            }
	            finally {
	                // Distributed cache could be removed from cluster only by
#destroyCache() call.
	                ignite.destroyCache(CACHE_NAME);
	            }
		   }

	}



--
View this message in context: http://apache-ignite-users.70518.x6.nabble.com/i-am-tring-to-load-mongo-store-but-i-am-getting-this-messege-tp13144.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Mime
View raw message