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