Re: what does remaps mean in DataStreamerImpl.java

Hi, How many backups (o.a.i.configuration.CacheConfiguration#setBackups) do you use? If your cluster does not contain backups, a batch will not remaped, until rebalance finished. -- View this message in context:

Re: Ignite errors in log

Hi Rishi, This means your node found another node with different 'java.net.preferIPv4Stack' value. Please, check if there is no other node running? On Wed, Apr 19, 2017 at 4:58 AM, Rishi Yagnik wrote: > Hello Andrew, > > I have applied IPv4 setting on both ignite

Re: what is the right way to run tests against Cassandra module?

Hi Alexei, Tests for Cassandra module should be executed just using standard maven approach: mvn clean test Igor On Apr 19, 2017 6:40 AM, "Alexei Kaigorodov" wrote: > the document DEVNOTES.txt says to run maven with argument > -Dtest=%TEST_PATTERN% > but cassandra

Re: Ignite errors in log

Hello Andrew, Thanks.. will dig further on it and will keep you posted. Thank you for all your help, Rishi On Wed, Apr 19, 2017 at 9:06 AM, Andrey Mashenkov < andrey.mashen...@gmail.com> wrote: > Hi Rishi, > > This means your node found another node with different > 'java.net.preferIPv4Stack'

what is the right way to run tests against Cassandra module?

the document DEVNOTES.txt says to run maven with argument -Dtest=%TEST_PATTERN% but cassandra test are placed in package org.apache.ignite.tests, where many other tests reside. When I run maven test from modules/cassandra directory, only 2 tests started. When I run tests from Intellij Idea, it

Re: what does remaps mean in DataStreamerImpl.java

Although, I'm not right (it should by remaper). Could you provide reproducer? -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/what-does-remaps-mean-in-DataStreamerImpl-java-tp12033p12079.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Disable WriteBehind

Hi, This is a very short test run on a small dataset on development laptop and is expected behavior. Is this log helpful or were you looking for something else? On Wed, Apr 19, 2017 at 4:55 AM, Nikolai Tikhonov-2 [via Apache Ignite Users] wrote: > Hi, > I see

WebConsole local install (v1.9) help needed

I'm having trouble with the WebConsole on my local Windows environment. I've done "npm install --no-optional" for both the "backend" and "frontend" and "npm start" for the "backend". However, whenever I try to do "npm run dev" for the "frontend", it doesn't look like it finishes. It gets to the

Re: what does remaps mean in DataStreamerImpl.java

Hi, the backup is in our case is 1. -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/what-does-remaps-mean-in-DataStreamerImpl-java-tp12033p12083.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: WebConsole local install (v1.9) help needed

It looks like it's working now. I think it was a proxy issue. -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/WebConsole-local-install-v1-9-help-needed-tp12086p12090.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Pessimistic TXN did not release lock on a key, all subsequent txns failed

Hi, I've reproduced the problem and have exatly the same stack traces for NullPointerException and IgniteTxTimeoutCheckedException that you mentioned early. But my case looks too complex. I started three nodes and cache1 on nodes N1, N2 and N3, and cache2 on nodes N1 and N2. After it deadlock

Re: Slow on 1st time query "SQL Join"

Hi, I believe it will be kept unless the cache is explicitly destroyed. Kind regards, Alex. On Tue, Apr 18, 2017 at 11:52 AM, woo charles [via Apache Ignite Users] < ml-node+s70518n12021...@n6.nabble.com> wrote: > Hi, > > For calling the function createMissingCaches(), it will create a cache in

Re: what does remaps mean in DataStreamerImpl.java

Hi Below is our architecture, 1. Ignite receives data via Kafka Streamer 2. Tuple Extractor is implemented in ignite code Everything works fine till this step. 3. We stop kafka. No error yet. 4. We kill 2 instance (out of n instance) of ignite. 5. Kafka Consumer remapping also happens without

Re: BinaryObjectImpl.deserializeValue with specific ClassLoader

Thanks, Dmitry! This is using Ignite 1.9. The stack trace is pretty straight forward: Putting things into caches works just fine (f.e. instances of that Namespace class), but pulling them out does not since the cache is only taking Ignite's classloader into account. For the time being I've had

Re: Pessimistic TXN did not release lock on a key, all subsequent txns failed

This is positive news Andrey. Thanks a lot. Please keep us posted about reproducing this. We are definitely not using node filters...and we suspect topology changes to be causing issues, but irrespective of that, we are not able to reproduce it. we also do not see deadlock issues reported

Re: Index

I tried REST API and H2 debug console. Do not see index, not sure what is wrong. I am creating cache pragmatically and can not use annotations. Below is the sample based on CacheQueryExample.java. Removed annotations from Person.java to create Person2.java /CacheConfiguration

Re: stdout - Message queue limit is set to 0, potential OOMEs

Thank you. Last question - Why it showing up with 1.9 and not earlier? Thanks, -Sam -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/stdout-Message-queue-limit-is-set-to-0-potential-OOMEs-tp12048p12091.html Sent from the Apache Ignite Users mailing list archive

Re: Use of Ignition.allGrids()

Hi, There are number of methods with confising names. Actually, gridName means ignite instance name. It will be fixed in 2.0 release. 1. Ignition.allGrids() return local JVM node instances. If you need all cluster nodes, see Ignite.cluster() method. 2. Both of you nodes belongs to same cluster

Re: Input data is no significant change in multi-threading

It may have effect if you prepare data for streamer (call addData) slowly and it is possible to utilize more resources for it. Of course remote nodes should be able to bear pressure of data. Performance can increased, but usually slightly as network will be a bottleneck. On Wed, Apr 19, 2017 at

Re: Use of Ignition.allGrids()

OK that all makes sense. Thanks Andrew -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Use-of-Ignition-allGrids-tp12071p12074.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Disable WriteBehind

Hi, I see again in the logs that node(app) lives only 5 seconds: *[15:36:04,897][INFO][main][GridDiscoveryManager] Topology snapshot [ver=1, servers=1, clients=0, CPUs=4, heap=0.5GB]* *[15:36:05,729][INFO][main][GridDeploymentLocalStore] Class locally deployed: class

Re: Input data is no significant change in multi-threading

When I call addData() in streamer. this data will send & buffer in server node. is that correct? If I correct, this data will buffer in random server node or only the one it directly connected? 2017-04-19 18:33 GMT+08:00 Andrey Mashenkov : > It may have effect if you

How to do write-behind caching?

Hello, can you provide a tutorial for* write-behind* caching? (similar to the one on this page https://dzone.com/articles/apache-ignite-how-to- read-data-from-persistent-sto but for *write-behind*). My configuration is the same as in the example provided in that page above (MySQL database), with

FailureDetectionTimeOut not working

Hi Team, I want to configure failureDetectionTimeOut so that I can customize after how long the clients get disconnected, in case of server failure. Just for testing purposes, I brought up one server and one client in a cluster, and had below property set: Heres my config:

Re: ScanQuery log all entries

Sam, Cursor iterator will go over whole result, but it will not hold in memory all dataset, just part limited by page size. In other words, it fetches 1024 entries, and when iterator points after last entry - loads another page with 1024 entries. So you shouldn't worry when results arrived - they

Re: stdout - Message queue limit is set to 0, potential OOMEs

What do you mean by messages? I am not using Ignite messaging. Are these messages of rebalancing during topology change? How do I configure it to avoid potential OOME? Thanks, -Sam -- View this message in context:

Re: stdout - Message queue limit is set to 0, potential OOMEs

Hi Sam, Ignite use messages for inter-node communication. You have to configure TcpCommunicationSPI in IgniteConfiguretion. Method TcpCommunicationSPI.setMessageQueueLimit() is what you need. On Wed, Apr 19, 2017 at 11:13 AM, javastuff@gmail.com < javastuff@gmail.com> wrote: > What do

Re: Input data is no significant change in multi-threading

Is that mean the performance of input data will not affect if I use 2 IgniteDataStreamer(2 client program) to input data as they use the same queue in remote nodes? 2017-04-19 10:02 GMT+08:00 Andrey Mashenkov : > Hi Woo, > > IgniteDataStreamer uses per node buffer to

Re: Index

Hi! You may try to use 1) https://apacheignite.readme.io/docs/rest-api#cache-metadata 2) org.apache.ignite.internal.visor.cache.VisorCacheMetadataTask (or see how it is implemented). But, PLEASE NOTE, this is internal API and may be changed in future versions of Ignite. On Tue, Apr 18, 2017 at

Use of Ignition.allGrids()

Hi, I'm a bit confused about the purpose of the Ignition.allGrids() method, and how also the naming of grids using the IgniteConfiguration works. I started a node using Ignition.getOrStart() with an IgniteConfiguration with name set to grid1, then create a cache and add some values to it. I

Re: what does remaps mean in DataStreamerImpl.java

1. So considering example from post 1, does it mean that when an ignite instance was killed, Data streamer had some data which it was going to put in to cache but that cache's instance was killed and hence the error might have occurred. 2. If not, than can you throw some light on the remap error