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