Re: Sharing Dataset Across Multiple Ignite Processes with Same Physical Page Mappings, SharedRDD

One update to this thread: I realized that the 2 nodes-50K keys to 4 nodes-25K redistribution was happening because I was not enforcing client mode at the spark worker side. However, my question still stands: Does Ignite use shared memory (shmem) to manage the Shared RDD? Can I set up Ignite serve

Re: ScanQuery with predicate always returns empty result.

Ah! I make silly mistakes too often. I will give it a try. I will also make a separate class instead of an inner class. Thanks! -- Thomas Isaksen From: ezhuravlev Sent: Friday, January 26, 2018 3:48:56 PM To: user@ignite.apache.org Subject: Re: ScanQuery with pre

Re: Failed to activate cluster - table already exists

Hi, I will share next time for sure. I tend to break stuff so I'm guessing I will do it again. As far as I can remember I didn't change anything before starting again. -- Thomas Isaksen From: Michael Cherkasov Sent: Friday, January 26, 2018 8:48:58 PM To: user@i

Re: Failed to activate cluster - table already exists

Hi Thomas, Please share with us next time a reproducer with work folder. It's something that should be checked. Did you change your QueryEntities between cluster restart? Thanks, Mike. 2018-01-26 5:25 GMT-08:00 Thomas Isaksen : > Hi Mikhail, > > I don't know what happened but I deleted some fo

Re: how to create instance of CacheManager of ignite

Denis cachingProvider.getCacheManager(URI uri, ClassLoader clsLdr) doesn't work, were you able to make it work? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Data lost when primary nodes down.

Hello! In Ignite, caches are usually partitioned. This means that data is split into some number e.g. 128) partitions, which are stored on a different nodes. For example, for three node cluster, one node (10.5.42.95) will store 1/3 of data in primary paritions and another 1/3 data in backup partit

RE: Question about data distribution

Hi, How many data entries do you have? Are IDs that you use for affinity mapping evenly distributed among the entries? Can you show the code that you use to define the affinity mapping and your cache configuration? Also, what exactly do you mean by "node gets X IDs to work with"? Do you mean t

Question about data distribution

Hi! I have two server nodes and I've set up an AffinityKey mapping via some ID. I'm streaming data from kafka to ignite and for my test data, about 5min worth of data belongs to one ID, then the data for the next ID starts (real data will mostly come in parallel). The cache I'm streaming the data

Re: ScanQuery with predicate always returns empty result.

Hi, in case when you use: ScanQuery scan = new ScanQuery<>((key, value) -> { System.out.println(key + “ = “ + value); return true; }) I think the problem is that you created ScanQuery while your cache is IgniteCache. Scan query should be too. In case of Inner cl

ScanQuery with predicate always returns empty result.

Hi I have the following code: IgniteCache skipCache = IgniteUtil.getCache("skipCache").withKeepBinary(); ScanQuery scan = new ScanQuery<>(); List> result = skipCache.query(scan).getAll(); This returns all the data in my cache. However, once I start using a predicate I get no data: ScanQuery s

RE: Failed to activate cluster - table already exists

Hi Mikhail, I don't know what happened but I deleted some folders under $IGNITE_HOME/work/db with the same name and the problem cleared. I think maybe I killed Ignite before it could finish writing or something to that effect, which could have caused the problem. ./t -Original Message-

Re: a2cf190a-6a44-4b94-baea-c9b88a16922e, class org.apache.ignite.IgniteCheckedException:Failed to execute SQL query

Hello! Most likely it's an error in SQL statement. Unfortunately, your stack trace is not enough to get to the root of problem. Logs from nodes should contain relevant information. You can share your logs from nodes, or search them yourself for IgniteCheckedException, post your findings. Regards,

Re: One problem about Cluster Configuration(cfg)

Rick, I can't reproduce the issue. Query"&qry=select+*+from+String" works fine for me. On Fri, Jan 26, 2018 at 12:57 PM, wrote: > Hello Andrey, > > > > 1. I have check the setting of cache is Partitioned and run two > nodes again. These program codes are respectively as follows: > > One no

RE: One problem about Cluster Configuration(cfg)

Hello Andrey, 1. I have check the setting of cache is Partitioned and run two nodes again. These program codes are respectively as follows: One node(shell script)==

Re: CacheStoreAdapter write and delete are not being called by Ignite's GridCacheStoreManager

Hi Slava, Guess I overlooked that part, thanx! -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

RE: Binary type has different affinity key fields

Hi Slava Thanks for pointing out my mistakes with the template. I have attached the java classes in question and the ignite config file that I am using . I create the table using DDL as follows: CREATE TABLE UserCache ( id bigint, username varchar, password varchar,

No transaction is currently active || Not allowed to create transaction on shared EntityManager - use Spring transactions or EJB CMT instead

Hi, First of all, yes I know Apache Ignite not support SQL Transaction. I hope this is not showstopper of my POC. I`m here to find another way. 1. I have function for update sequence table. private int sequenceManual(String seqName) { int seq = 0; Query query; try {

Re: One problem about Cluster Configuration(cfg)

Rick, 1. As you are able to put entry to cache, you should see cache.get() result in console. Please, check cache is not Local, but Partitioned or Replicated. 2. Also check the topology version message. You should see 2 servers in it. 3. Try to select value explicitly via _val field. E.g. "SELEC