Hello! Is this cache also defined on server node? Only the first cache configuration is used to create it, and all other ones are thrown away (just the name is used).
Regards, -- Ilya Kasnacheev вт, 12 февр. 2019 г. в 06:39, Max Barrios <[email protected]>: > Hi, > > This is the code fragment from MyIgniteTest.scala: > > val cassandraDataSource = new DataSource > cassandraDataSource.setContactPoints("10.0.0.1") > val robinPolicy = new RoundRobinPolicy > cassandraDataSource.setLoadBalancingPolicy(robinPolicy) > cassandraDataSource.setReadConsistency("ONE") > cassandraDataSource.setWriteConsistency("ONE") > > // Read the persistence settings for Cassandra Key-Value persistance > val persistenceSettings = new > KeyValuePersistenceSettings("./src/main/resources/default-cassandra-store.xml") > > // Define Cassandra cache store factory, set the cassandra dataSource > and persistence settings > val cassandraCacheStoreFactory = new CassandraCacheStoreFactory > cassandraCacheStoreFactory.setDataSource(cassandraDataSource) > cassandraCacheStoreFactory.setPersistenceSettings(persistenceSettings) > > // Define the cache configuration, set the cassandraCacheStoreFactory > as cacheStoreFactory , enable write through, write behind and read through > val cassandraConfiguration = new CacheConfiguration > cassandraConfiguration.setCacheStoreFactory(cassandraCacheStoreFactory) > > // Sets the cache configuration > val cfg = new IgniteConfiguration > cfg.setCacheConfiguration(cassandraConfiguration) > > // Starting Ignite. > Ignition.setClientMode(true) > val ignite = Ignition.start(cfg) > > > Thanks, > > Max > > On Mon, 11 Feb 2019 at 07:58, Ilya Kasnacheev <[email protected]> > wrote: > >> Hello! >> >> How do you pass CassandraCacheStoreFactory to your cache configuration? >> >> I can see XML fragment and code fragment in your first message, which one >> are you using? In your code fragment there's no call of cache configuration >> setter. >> >> Regards, >> -- >> Ilya Kasnacheev >> >> >> пт, 8 февр. 2019 г. в 23:01, Max Barrios <[email protected]>: >> >>> Hi, >>> >>> Stack trace is below: >>> >>> [error] 19/02/07 22:17:14 ERROR GridDhtPartitionsExchangeFuture: Failed to >>> reinitialize local partitions (preloading will be stopped): >>> GridDhtPartitionExchangeId [topVer=AffinityTopologyVersion [topVer=10, >>> minorTopVer=0], discoEvt=DiscoveryEvent [evtNode=TcpDiscoveryNode >>> [id=0a3b5352-592c-450c-912c-7fe401cc4415, addrs=[0:0:0:0:0:0:0:1%lo, >>> 10.0.0.1, 127.0.0.1], sockAddrs=[ignite-node-01/10.0.0.1:0, >>> /0:0:0:0:0:0:0:1%lo:0, /127.0.0.1:0], discPort=0, order=10, intOrder=0, >>> lastExchangeTime=1549577833007, loc=true, ver=2.6.0#20180710-sha1:669feacc, >>> isClient=true], topVer=10, nodeId8=0a3b5352, msg=null, type=NODE_JOINED, >>> tstamp=1549577833993], nodeId=0a3b5352, evt=NODE_JOINED] >>> [error] java.lang.IllegalStateException: Failed to get Cassandra DataSource >>> cause Spring application context wasn't injected into >>> CassandraCacheStoreFactory >>> [error] at >>> org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory.getDataSource(CassandraCacheStoreFactory.java:124) >>> [error] at >>> org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory.create(CassandraCacheStoreFactory.java:59) >>> [error] at >>> org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory.create(CassandraCacheStoreFactory.java:34) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCacheProcessor.createCache(GridCacheProcessor.java:1437) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCacheProcessor.prepareCacheStart(GridCacheProcessor.java:1945) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCacheProcessor.startCachesOnLocalJoin(GridCacheProcessor.java:1830) >>> [error] at >>> org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture.initCachesOnLocalJoin(GridDhtPartitionsExchangeFuture.java:792) >>> [error] at >>> org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture.init(GridDhtPartitionsExchangeFuture.java:674) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$ExchangeWorker.body0(GridCachePartitionExchangeManager.java:2419) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$ExchangeWorker.body(GridCachePartitionExchangeManager.java:2299) >>> [error] at >>> org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:110) >>> [error] at java.lang.Thread.run(Thread.java:748) >>> [error] 19/02/07 22:17:14 INFO GridDhtPartitionsExchangeFuture: Finish >>> exchange future [startVer=AffinityTopologyVersion [topVer=10, >>> minorTopVer=0], resVer=null, err=java.lang.IllegalStateException: Failed to >>> get Cassandra DataSource cause Spring application context wasn't injected >>> into CassandraCacheStoreFactory] >>> [error] 19/02/07 22:17:14 ERROR IgniteKernal: Got exception while starting >>> (will rollback startup routine). >>> [error] class org.apache.ignite.IgniteCheckedException: Failed to get >>> Cassandra DataSource cause Spring application context wasn't injected into >>> CassandraCacheStoreFactory >>> [error] at >>> org.apache.ignite.internal.util.IgniteUtils.cast(IgniteUtils.java:7307) >>> [error] at >>> org.apache.ignite.internal.util.future.GridFutureAdapter.resolve(GridFutureAdapter.java:259) >>> [error] at >>> org.apache.ignite.internal.util.future.GridFutureAdapter.get0(GridFutureAdapter.java:232) >>> [error] at >>> org.apache.ignite.internal.util.future.GridFutureAdapter.get(GridFutureAdapter.java:159) >>> [error] at >>> org.apache.ignite.internal.util.future.GridFutureAdapter.get(GridFutureAdapter.java:151) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager.onKernalStart(GridCachePartitionExchangeManager.java:635) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCacheProcessor.onKernalStart(GridCacheProcessor.java:875) >>> [error] at >>> org.apache.ignite.internal.IgniteKernal.start(IgniteKernal.java:1086) >>> [error] at >>> org.apache.ignite.internal.IgnitionEx$IgniteNamedInstance.start0(IgnitionEx.java:2014) >>> [error] at >>> org.apache.ignite.internal.IgnitionEx$IgniteNamedInstance.start(IgnitionEx.java:1723) >>> [error] at >>> org.apache.ignite.internal.IgnitionEx.start0(IgnitionEx.java:1151) >>> [error] at >>> org.apache.ignite.internal.IgnitionEx.start(IgnitionEx.java:671) >>> [error] at >>> org.apache.ignite.internal.IgnitionEx.start(IgnitionEx.java:611) >>> [error] at org.apache.ignite.Ignition.getOrStart(Ignition.java:419) >>> [error] at >>> org.apache.ignite.spark.IgniteContext.ignite(IgniteContext.scala:150) >>> [error] at >>> org.apache.ignite.spark.IgniteContext.<init>(IgniteContext.scala:63) >>> [error] at >>> org.apache.ignite.spark.IgniteContext.<init>(IgniteContext.scala:86) >>> [error] at MyIgniteTest$.main(MyIgniteTest.scala:160) >>> [error] at MyIgniteTest.main(MyIgniteTest.scala) >>> [error] Caused by: java.lang.IllegalStateException: Failed to get Cassandra >>> DataSource cause Spring application context wasn't injected into >>> CassandraCacheStoreFactory >>> [error] at >>> org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory.getDataSource(CassandraCacheStoreFactory.java:124) >>> [error] at >>> org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory.create(CassandraCacheStoreFactory.java:59) >>> [error] at >>> org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory.create(CassandraCacheStoreFactory.java:34) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCacheProcessor.createCache(GridCacheProcessor.java:1437) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCacheProcessor.prepareCacheStart(GridCacheProcessor.java:1945) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCacheProcessor.startCachesOnLocalJoin(GridCacheProcessor.java:1830) >>> [error] at >>> org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture.initCachesOnLocalJoin(GridDhtPartitionsExchangeFuture.java:792) >>> [error] at >>> org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture.init(GridDhtPartitionsExchangeFuture.java:674) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$ExchangeWorker.body0(GridCachePartitionExchangeManager.java:2419) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$ExchangeWorker.body(GridCachePartitionExchangeManager.java:2299) >>> [error] at >>> org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:110) >>> [error] at java.lang.Thread.run(Thread.java:748) >>> [error] 19/02/07 22:17:14 ERROR GridCachePartitionExchangeManager: Failed >>> to wait for completion of partition map exchange (preloading will not >>> start): GridDhtPartitionsExchangeFuture [firstDiscoEvt=DiscoveryEvent >>> [evtNode=TcpDiscoveryNode [id=0a3b5352-592c-450c-912c-7fe401cc4415, >>> addrs=[0:0:0:0:0:0:0:1%lo, 10.0.0.1, 127.0.0.1], >>> sockAddrs=[ignite-node-01/10.0.0.1:0, /0:0:0:0:0:0:0:1%lo:0, /127.0.0.1:0], >>> discPort=0, order=10, intOrder=0, lastExchangeTime=1549577833007, loc=true, >>> ver=2.6.0#20180710-sha1:669feacc, isClient=true], topVer=10, >>> nodeId8=0a3b5352, msg=null, type=NODE_JOINED, tstamp=1549577833993], >>> crd=TcpDiscoveryNode [id=56340b23-60c1-4d7d-a19e-fb51066b4858, >>> addrs=[0:0:0:0:0:0:0:1%lo, 10.0.0.1, 127.0.0.1], >>> sockAddrs=[/0:0:0:0:0:0:0:1%lo:47500, /127.0.0.1:47500, >>> ignite-node-01/10.0.0.1:47500], discPort=47500, order=1, intOrder=1, >>> lastExchangeTime=1549577833932, loc=false, >>> ver=2.6.0#20180710-sha1:669feacc, isClient=false], >>> exchId=GridDhtPartitionExchangeId [topVer=AffinityTopologyVersion >>> [topVer=10, minorTopVer=0], discoEvt=DiscoveryEvent >>> [evtNode=TcpDiscoveryNode [id=0a3b5352-592c-450c-912c-7fe401cc4415, >>> addrs=[0:0:0:0:0:0:0:1%lo, 10.0.0.1, 127.0.0.1], >>> sockAddrs=[ignite-node-01/10.0.0.1:0, /0:0:0:0:0:0:0:1%lo:0, /127.0.0.1:0], >>> discPort=0, order=10, intOrder=0, lastExchangeTime=1549577833007, loc=true, >>> ver=2.6.0#20180710-sha1:669feacc, isClient=true], topVer=10, >>> nodeId8=0a3b5352, msg=null, type=NODE_JOINED, tstamp=1549577833993], >>> nodeId=0a3b5352, evt=NODE_JOINED], added=true, initFut=GridFutureAdapter >>> [ignoreInterrupts=false, state=DONE, res=false, hash=786357198], >>> init=false, lastVer=null, partReleaseFut=null, exchActions=null, >>> affChangeMsg=null, initTs=1549577834024, centralizedAff=false, >>> forceAffReassignment=false, changeGlobalStateE=null, done=true, >>> state=CLIENT, evtLatch=0, remaining=[56340b23-60c1-4d7d-a19e-fb51066b4858, >>> 38b9e6a1-131d-43c9-aac2-60d129faa9bd, >>> e9f79e0b-00eb-4752-afc5-be91185d56c4], super=GridFutureAdapter >>> [ignoreInterrupts=false, state=DONE, res=java.lang.IllegalStateException: >>> Failed to get Cassandra DataSource cause Spring application context wasn't >>> injected into CassandraCacheStoreFactory, hash=21748544]] >>> [error] class org.apache.ignite.IgniteCheckedException: Failed to get >>> Cassandra DataSource cause Spring application context wasn't injected into >>> CassandraCacheStoreFactory >>> [error] at >>> org.apache.ignite.internal.util.IgniteUtils.cast(IgniteUtils.java:7307) >>> [error] at >>> org.apache.ignite.internal.util.future.GridFutureAdapter.resolve(GridFutureAdapter.java:259) >>> [error] at >>> org.apache.ignite.internal.util.future.GridFutureAdapter.get0(GridFutureAdapter.java:207) >>> [error] at >>> org.apache.ignite.internal.util.future.GridFutureAdapter.get(GridFutureAdapter.java:159) >>> [error] at >>> org.apache.ignite.internal.util.future.GridFutureAdapter.get(GridFutureAdapter.java:151) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$ExchangeWorker.body0(GridCachePartitionExchangeManager.java:2433) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$ExchangeWorker.body(GridCachePartitionExchangeManager.java:2299) >>> [error] at >>> org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:110) >>> [error] at java.lang.Thread.run(Thread.java:748) >>> [error] Caused by: java.lang.IllegalStateException: Failed to get Cassandra >>> DataSource cause Spring application context wasn't injected into >>> CassandraCacheStoreFactory >>> [error] at >>> org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory.getDataSource(CassandraCacheStoreFactory.java:124) >>> [error] at >>> org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory.create(CassandraCacheStoreFactory.java:59) >>> [error] at >>> org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory.create(CassandraCacheStoreFactory.java:34) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCacheProcessor.createCache(GridCacheProcessor.java:1437) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCacheProcessor.prepareCacheStart(GridCacheProcessor.java:1945) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCacheProcessor.startCachesOnLocalJoin(GridCacheProcessor.java:1830) >>> [error] at >>> org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture.initCachesOnLocalJoin(GridDhtPartitionsExchangeFuture.java:792) >>> [error] at >>> org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture.init(GridDhtPartitionsExchangeFuture.java:674) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$ExchangeWorker.body0(GridCachePartitionExchangeManager.java:2419) >>> [error] ... 3 more >>> [error] 19/02/07 22:17:14 INFO GridCacheProcessor: Stopped cache >>> [cacheName=ignite-sys-cache] >>> [error] 19/02/07 22:17:14 INFO IgniteKernal: >>> [error] >>> >>> +---------------------------------------------------------------------------------+ >>> [error] >>> Ignite ver. >>> 2.6.0#20180710-sha1:669feacc5d3a4e60efcdd300dc8de99780f38eed stopped OK >>> [error] >>> >>> +---------------------------------------------------------------------------------+ >>> [error] >>> Grid uptime: 00:00:02.620 >>> [error] 19/02/07 22:17:14 ERROR IgniteContext: Failed to start Ignite. >>> [error] class org.apache.ignite.IgniteException: Failed to get Cassandra >>> DataSource cause Spring application context wasn't injected into >>> CassandraCacheStoreFactory >>> [error] at >>> org.apache.ignite.internal.util.IgniteUtils.convertException(IgniteUtils.java:990) >>> [error] at org.apache.ignite.Ignition.getOrStart(Ignition.java:422) >>> [error] at >>> org.apache.ignite.spark.IgniteContext.ignite(IgniteContext.scala:150) >>> [error] at >>> org.apache.ignite.spark.IgniteContext.<init>(IgniteContext.scala:63) >>> [error] at >>> org.apache.ignite.spark.IgniteContext.<init>(IgniteContext.scala:86) >>> [error] at MyIgniteTest$.main(MyIgniteTest.scala:160) >>> [error] at MyIgniteTest.main(MyIgniteTest.scala) >>> [error] Caused by: class org.apache.ignite.IgniteCheckedException: Failed >>> to get Cassandra DataSource cause Spring application context wasn't >>> injected into CassandraCacheStoreFactory >>> [error] at >>> org.apache.ignite.internal.util.IgniteUtils.cast(IgniteUtils.java:7307) >>> [error] at >>> org.apache.ignite.internal.util.future.GridFutureAdapter.resolve(GridFutureAdapter.java:259) >>> [error] at >>> org.apache.ignite.internal.util.future.GridFutureAdapter.get0(GridFutureAdapter.java:232) >>> [error] at >>> org.apache.ignite.internal.util.future.GridFutureAdapter.get(GridFutureAdapter.java:159) >>> [error] at >>> org.apache.ignite.internal.util.future.GridFutureAdapter.get(GridFutureAdapter.java:151) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager.onKernalStart(GridCachePartitionExchangeManager.java:635) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCacheProcessor.onKernalStart(GridCacheProcessor.java:875) >>> [error] at >>> org.apache.ignite.internal.IgniteKernal.start(IgniteKernal.java:1086) >>> [error] at >>> org.apache.ignite.internal.IgnitionEx$IgniteNamedInstance.start0(IgnitionEx.java:2014) >>> [error] at >>> org.apache.ignite.internal.IgnitionEx$IgniteNamedInstance.start(IgnitionEx.java:1723) >>> [error] at >>> org.apache.ignite.internal.IgnitionEx.start0(IgnitionEx.java:1151) >>> [error] at >>> org.apache.ignite.internal.IgnitionEx.start(IgnitionEx.java:671) >>> [error] at >>> org.apache.ignite.internal.IgnitionEx.start(IgnitionEx.java:611) >>> [error] at org.apache.ignite.Ignition.getOrStart(Ignition.java:419) >>> [error] ... 5 more >>> [error] Caused by: java.lang.IllegalStateException: Failed to get Cassandra >>> DataSource cause Spring application context wasn't injected into >>> CassandraCacheStoreFactory >>> [error] at >>> org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory.getDataSource(CassandraCacheStoreFactory.java:124) >>> [error] at >>> org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory.create(CassandraCacheStoreFactory.java:59) >>> [error] at >>> org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory.create(CassandraCacheStoreFactory.java:34) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCacheProcessor.createCache(GridCacheProcessor.java:1437) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCacheProcessor.prepareCacheStart(GridCacheProcessor.java:1945) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCacheProcessor.startCachesOnLocalJoin(GridCacheProcessor.java:1830) >>> [error] at >>> org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture.initCachesOnLocalJoin(GridDhtPartitionsExchangeFuture.java:792) >>> [error] at >>> org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture.init(GridDhtPartitionsExchangeFuture.java:674) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$ExchangeWorker.body0(GridCachePartitionExchangeManager.java:2419) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$ExchangeWorker.body(GridCachePartitionExchangeManager.java:2299) >>> [error] at >>> org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:110) >>> [error] at java.lang.Thread.run(Thread.java:748) >>> [error] Exception in thread "main" class org.apache.ignite.IgniteException: >>> Failed to get Cassandra DataSource cause Spring application context wasn't >>> injected into CassandraCacheStoreFactory >>> [error] at >>> org.apache.ignite.internal.util.IgniteUtils.convertException(IgniteUtils.java:990) >>> [error] at org.apache.ignite.Ignition.getOrStart(Ignition.java:422) >>> [error] at >>> org.apache.ignite.spark.IgniteContext.ignite(IgniteContext.scala:150) >>> [error] at >>> org.apache.ignite.spark.IgniteContext.<init>(IgniteContext.scala:63) >>> [error] at >>> org.apache.ignite.spark.IgniteContext.<init>(IgniteContext.scala:86) >>> [error] at MyIgniteTest$.main(MyIgniteTest.scala:160) >>> [error] at MyIgniteTest.main(MyIgniteTest.scala) >>> [error] Caused by: class org.apache.ignite.IgniteCheckedException: Failed >>> to get Cassandra DataSource cause Spring application context wasn't >>> injected into CassandraCacheStoreFactory >>> [error] at >>> org.apache.ignite.internal.util.IgniteUtils.cast(IgniteUtils.java:7307) >>> [error] at >>> org.apache.ignite.internal.util.future.GridFutureAdapter.resolve(GridFutureAdapter.java:259) >>> [error] at >>> org.apache.ignite.internal.util.future.GridFutureAdapter.get0(GridFutureAdapter.java:232) >>> [error] at >>> org.apache.ignite.internal.util.future.GridFutureAdapter.get(GridFutureAdapter.java:159) >>> [error] at >>> org.apache.ignite.internal.util.future.GridFutureAdapter.get(GridFutureAdapter.java:151) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager.onKernalStart(GridCachePartitionExchangeManager.java:635) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCacheProcessor.onKernalStart(GridCacheProcessor.java:875) >>> [error] at >>> org.apache.ignite.internal.IgniteKernal.start(IgniteKernal.java:1086) >>> [error] at >>> org.apache.ignite.internal.IgnitionEx$IgniteNamedInstance.start0(IgnitionEx.java:2014) >>> [error] at >>> org.apache.ignite.internal.IgnitionEx$IgniteNamedInstance.start(IgnitionEx.java:1723) >>> [error] at >>> org.apache.ignite.internal.IgnitionEx.start0(IgnitionEx.java:1151) >>> [error] at >>> org.apache.ignite.internal.IgnitionEx.start(IgnitionEx.java:671) >>> [error] at >>> org.apache.ignite.internal.IgnitionEx.start(IgnitionEx.java:611) >>> name := "myignitetest" >>> [error] at org.apache.ignite.Ignition.getOrStart(Ignition.java:419) >>> [error] ... 5 more >>> [error] Caused by: java.lang.IllegalStateException: Failed to get Cassandra >>> DataSource cause Spring application context wasn't injected into >>> CassandraCacheStoreFactory >>> Added com.google.common 1.6 dependancy >>> [error] at >>> org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory.getDataSource(CassandraCacheStoreFactory.java:124) >>> [error] at >>> org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory.create(CassandraCacheStoreFactory.java:59) >>> [error] at >>> org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory.create(CassandraCacheStoreFactory.java:34) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCacheProcessor.createCache(GridCacheProcessor.java:1437) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCacheProcessor.prepareCacheStart(GridCacheProcessor.java:1945) >>> [error] at >>> org.apache.ignite.internal.processors.cache.GridCacheProcessor.startCachesOnLocalJoin(GridCacheProcessor.java:1830) >>> [error] at >>> org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture.initCachesOnLocalJoin(GridDhtPartitionsExchangeFuture.java:792) >>> >>> >>> Thanks! >>> >>> Max >>> >>> On Fri, 8 Feb 2019 at 01:26, Ilya Kasnacheev <[email protected]> >>> wrote: >>> >>>> Hello! >>>> >>>> Can you provide stack trace of the exception? >>>> >>>> Regards, >>>> -- >>>> Ilya Kasnacheev >>>> >>>> >>>> пт, 8 февр. 2019 г. в 01:33, Max Barrios <[email protected]>: >>>> >>>>> FYI I am using Ignite Fabric 2.6.0. We use Spark 2.3.2 / Hadoop 2.8.5 >>>>> so upgrading to Ignite 2.7.0 means upgrading Spark/Hadoop. >>>>> >>>>> On Thu, 7 Feb 2019 at 11:58, Max Barrios <[email protected]> >>>>> wrote: >>>>> >>>>>> As far as I know, yes. Where would/should I look to check? >>>>>> >>>>>> Also, do I need to copy the ignite cassandra libraries to my client >>>>>> to build that client? >>>>>> >>>>>> On Thu, 7 Feb 2019 at 06:47, Ilya Kasnacheev < >>>>>> [email protected]> wrote: >>>>>> >>>>>>> Hello! >>>>>>> >>>>>>> This is unusual, since you have set cassandraDataSource directly >>>>>>> and bean/app context should not be checked when you do. >>>>>>> Are you sure that it is the only cassandra cache store factory that >>>>>>> gets used in actual caches? >>>>>>> >>>>>>> Regards, >>>>>>> -- >>>>>>> Ilya Kasnacheev >>>>>>> >>>>>>> >>>>>>> чт, 7 февр. 2019 г. в 05:59, Max Barrios <[email protected]>: >>>>>>> >>>>>>>> I am running an application written in Scala that is using Spark, >>>>>>>> Ignite, and persisting from writeThrough cache to Cassandra. From the >>>>>>>> Ignite base concepts code you are supposed to set the >>>>>>>> CacheStoreFactory as >>>>>>>> such: >>>>>>>> >>>>>>>> <property name="cacheStoreFactory"> >>>>>>>> <bean >>>>>>>> class="org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory"> >>>>>>>> <!-- Datasource configuration bean which is responsible for >>>>>>>> Cassandra connection details --> >>>>>>>> <property name="dataSourceBean" value="cassandraDataSource"/> >>>>>>>> <!-- Persistent settings bean which is responsible for the >>>>>>>> details of how objects will be persisted to Cassandra --> >>>>>>>> <property name="persistenceSettingsBean" >>>>>>>> value="cache1_persistence_settings"/> >>>>>>>> </bean></property> >>>>>>>> >>>>>>>> Yet, when I run the application I get the error: >>>>>>>> >>>>>>>> java.lang.IllegalStateException: >>>>>>>> Failed to get Cassandra DataSource cause Spring application context >>>>>>>> wasn't injected into CassandraCacheStoreFactory >>>>>>>> >>>>>>>> All of the Ignite.xml, connection-settings.xml and >>>>>>>> cassandra-store.xml are all written the same way as the examples >>>>>>>> explain on >>>>>>>> apacheignite Cassandra integration page. >>>>>>>> >>>>>>>> I am initializing the CassandraCacheStoreFactory as follows: >>>>>>>> >>>>>>>> >>>>>>>> val cassandraDataSource = new DataSource >>>>>>>> cassandraDataSource.setContactPoints("prod-cassandra-db.ct.corp") >>>>>>>> val robinPolicy = new RoundRobinPolicy >>>>>>>> cassandraDataSource.setLoadBalancingPolicy(robinPolicy) >>>>>>>> cassandraDataSource.setReadConsistency("ONE") >>>>>>>> cassandraDataSource.setWriteConsistency("ONE") >>>>>>>> >>>>>>>> val CONFIG = "src/main/resources/default-cassandra-store.xml" >>>>>>>> val persistenceSettings = new KeyValuePersistenceSettings(CONFIG) >>>>>>>> val cassandraCacheStoreFactory = new CassandraCacheStoreFactory >>>>>>>> cassandraCacheStoreFactory.setDataSource(cassandraDataSource) >>>>>>>> >>>>>>>> cassandraCacheStoreFactory.setPersistenceSettings(persistenceSettings) >>>>>>>> >>>>>>>> And I am starting the Ignite code as follows: >>>>>>>> >>>>>>>> val igniteContext = new IgniteContext(sparkContext, >>>>>>>> config.igniteConfig, true) >>>>>>>> val ignite = igniteContext.ignite() >>>>>>>> >>>>>>>> What am I missing or doing wrong that is causing this error? I have >>>>>>>> yet to find a simple, comprehensive example in Scala for doing this. >>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>>
