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