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