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. >>>>>> >>>>>> >>>>>> >>>>>>
