Re: Ignite 1.6.0 suspected memory leak from DynamicCacheDescriptor

2016-12-14 Thread tysli2016
What do you mean by "embedded instances"? if it's org.apache.ignite.Ignite object then we have two, one for each .war application deployed. And what do you mean by "not properly stopped and / or disconnected"? The application call org.apache.ignite.Ignite.close() only when Tomcat shutdown. What if

Re: Server/Client Nodes and classes

2016-12-14 Thread vkulichenko
CacheStore can be called on client node, in particular if TRANSACTIONAL cache is used. Transactional cache updates the store from a node which coordinates a transaction which is usually a client. This is not needed for ATOMIC caches though and can be improved, we have a ticket for this [1]. For no

Server/Client Nodes and classes

2016-12-14 Thread juanavelez
I am having the following situation: I have a 4-node cluster with write-through enabled using an in-house developed MongoDB Cache Store. The spring configuration xml file for the servers include beans for the mongo client, mongo codecs, ignite caches stores, etc. I can successfully start the 4-node

Re: Hibernate OGM and Ignite (beginning of the story)

2016-12-14 Thread Prachi Garg
Shamim, Your blog has been added to the Ignite blog list- https://ignite.apache.org/blogs.html -Prachi On Tue, Dec 13, 2016 at 4:35 PM, Denis Magda wrote: > Shamim, great thanks! > > Copying our conversion to Ignite’s dev and user lists. > > Igniters, Shamim posted a useful blog post about the

Re: Difference between cache.clear() versus cache.remove()

2016-12-14 Thread vkulichenko
clear() only removes entries from in-memory cache. remove() is full-pledged update operation, which does write-through, can be enlisted in transaction, guarantees consistency, etc. -Val -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Difference-between-cache-cle

Difference between cache.clear() versus cache.remove()

2016-12-14 Thread styriver
Hello what is the difference between cache.clear() versus cache.remove()? Reviewing developer posts I see that the behavior of .clear() might be changing in 1.9. We are using the newest 1.8 release right now. -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Diffe

Re: Index wont't be used with QueryEntity configuration

2016-12-14 Thread vkulichenko
When configuring with QueryEntity, Ignite doesn't now the exact field type, so it creates a regular sorted index by default. You need to specify that this is a geospatial index explicitly: new QueryIndex("coords", QueryIndexType.GEOSPATIAL) -Val -- View this message in context: http://apache-

Re: Apache Spark & Ignite Integration

2016-12-14 Thread vkulichenko
First of all, I'm not sure how it works with Dataframes. Since we don't have Dataframe support yet, only RDD, using Dataframe can potentially not work as we expect (I don't have enough Spark expertise to tell if this is the case or not). The only way to check this is to create tests. Other than th

Re: Ignite 1.6.0 suspected memory leak from DynamicCacheDescriptor

2016-12-14 Thread vkulichenko
It seems to me you have a lot of embedded instances that are not properly stopped and/or disconnected. Can this be the case. How many instances of GridKernalContextImpl do you have in heap? -Val -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Ignite-1-6-0-suspec

Re: Encyrption of Data at REST in Apache Ignite

2016-12-14 Thread vkulichenko
Encryption between nodes is possible, but it's enabled separately from REST [1]. Encryption of stored data is not supported out of the box, but you can try to use CacheInterceptor [1] to support this. Note that it will break SQL query execution, so if you're going to use them, I don't think encryp

Re: Are IgniteCache instances thread-safe?

2016-12-14 Thread juanavelez
Great to know. Thanks! > On 14 Dec, 2016, at 10:49 AM, vkulichenko [via Apache Ignite Users] > wrote: > > Hi, > > Yes, all Ignite APIs including IgniteCache are thread safe and it's OK to use > it concurrently from multiple threads. Actually, calling Ignite.cache() > method does not create a

Re: Are IgniteCache instances thread-safe?

2016-12-14 Thread vkulichenko
Hi, Yes, all Ignite APIs including IgniteCache are thread safe and it's OK to use it concurrently from multiple threads. Actually, calling Ignite.cache() method does not create a new instance, but returns an existing one, so you will end reusing the same instance anyway. -Val -- View this mess

Re: Detecting terminal condition for group of items in Ignite cache.

2016-12-14 Thread begineer
Thanks for reply first of all. Well I had this in back of my mind but it will be like duplicating the data which we already have in other cache(trades cache which I am currently querying). So other way I can think of is using spring scheduler with 1 minute fix-rate and check if any item moved to S

Index wont't be used with QueryEntity configuration

2016-12-14 Thread Rafael Troilo
Hi, I just try out the SpatialQueryExample and don't want to us annotations for the MapPoint class, but I have trouble to get the index to work. Here is what I see: CacheConfiguration cc = new CacheConfiguration<>(CACHE_NAME); SQL: "explain analyze select _val from MapPoint where coords &

Are IgniteCache instances thread-safe?

2016-12-14 Thread juanavelez
I apologize in advance if this has been answered previously (search on this forum did not return any related posts though). I am trying to determine if I create a singleton of an IgniteCache and inject that into different POJOs which are managed by different threads, will the IgniteCache instance

Re: Cache stopped

2016-12-14 Thread Anil
i see network segmentation in logs. ignore my previous question. thanks. On 14 December 2016 at 16:06, Anil wrote: > > You are correct. i am using vertx-ignite. i dont understand the reason for > stopping the ignite. > > I am using KafkaStreamer and it must be stopped on a node when is it leave

Re: Apache Ignite 1.8 Released

2016-12-14 Thread thammoud
Will keep an eye. Still not up as of today. Sending it by snail mail :) -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Apache-Ignite-1-8-Released-tp9483p9535.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Detecting terminal condition for group of items in Ignite cache.

2016-12-14 Thread Taras Ledkov
Hi, What do you think about an atomic counter of not successful trades, e.g. the atomic cache with a company name as a key and Integer as a counter. You can update the counter when add trade (increment) and at the listener of the continuous query (decrement) and do something when counter equals ze

Re: Not able to join cluster with Zookeeper based IP finder

2016-12-14 Thread Nikolai Tikhonov
I understand your problem and seems we got bottom this issue. Your implementation is incorrect. Address resolver invoked not only for local address and also for external addresses. You need to change the logic from AddressResolver addressResolver = (InetSocketAddress address) -> Collections.si

Re: Not able to join cluster with Zookeeper based IP finder

2016-12-14 Thread ghughal
Nikolai Tikhonov-2 wrote > Hi! > > It's right way to use AddressResolver for deployment in docker. Could you > please share your address resolver implementation? Here's code we are using to configure AddressResolver. Like I mentioned earlier, it's not that this code is not working. It works fine

Re: Ignite cluster

2016-12-14 Thread Anil
Hi Anton, Thank you very much. On 14 December 2016 at 17:49, Anton Vinogradov wrote: > Anil, > > This situation described here https://gridgain.readme. > io/docs/network-segmentation > > > > On Wed, Dec 14, 2016 at 2:48 PM, Anil wrote: > >> HI, >> >> how ignite cluster internally behaves whe

Re: Ignite cluster

2016-12-14 Thread Anton Vinogradov
Anil, This situation described here https://gridgain.readme.io/docs/network-segmentation On Wed, Dec 14, 2016 at 2:48 PM, Anil wrote: > HI, > > how ignite cluster internally behaves when a node disconnects from cluster > ? > > Lets say A , B, C are three nodes formed ignite cluster. > > When

Re: Not able to join cluster with Zookeeper based IP finder

2016-12-14 Thread Nikolai Tikhonov
Hi! It's right way to use AddressResolver for deployment in docker. Could you please share your address resolver implementation? On Sat, Dec 10, 2016 at 9:41 AM, Yakov Zhdanov wrote: > Nikolay, can you please join this thread and point out how to build > cluster using docker? > > --Yakov > > 20

Re: How can I save the job result which was ran on server which lost the connection.

2016-12-14 Thread Pavel Tupitsyn
There is no checkpointing support in .NET yet, but we certainly have plans for it: https://issues.apache.org/jira/browse/IGNITE-4427 On Wed, Dec 14, 2016 at 1:42 AM, vkulichenko wrote: > No, unfortunately not. Probably someone closer to this topic can tell if > there are any plans to add this su

Ignite cluster

2016-12-14 Thread Anil
HI, how ignite cluster internally behaves when a node disconnects from cluster ? Lets say A , B, C are three nodes formed ignite cluster. When A disconnects from the cluster, ignite instance on A is still run ? now will there be two clusters A , B & C ? Please clarify. Thanks

Detecting terminal condition for group of items in Ignite cache.

2016-12-14 Thread begineer
Hi, My sample application processes trades for different companies stored in Ignite cache. When all trades for particular company reaches SUCCESS stage, an automatic notification should be triggered and some other system/application will react to it. To do this, When ever any trade reaches SUCCESS

Re: Cache stopped

2016-12-14 Thread Anil
You are correct. i am using vertx-ignite. i dont understand the reason for stopping the ignite. I am using KafkaStreamer and it must be stopped on a node when is it leave the ignite cluster. Do you have any suggestions ? I mean - Lets say there are two ignite nodes (A & B). when ignite is starte

Re: Building complex queries to query ignite Cache

2016-12-14 Thread begineer
Thanks for reply. This is perfect and much simpler if I have to get counts of various statuses. Although using this approach to build 3D kind of mapping(i.e. sample table shown in reply 2 in this thread) requires a lot of manipulation to data. Thanks all for help. Will come back again if more hel

Re: Cache stopped

2016-12-14 Thread Alexandr Kuramshin
It's seems that you are trying to getOrCreateCache after the grid was stopped. Message recieved by KafkaCacheDataStreamer's running in a parrallel thread (pool-6-thread-1). You should first stop all streaming threads and then stop the grid. 2016-12-14 11:12 GMT+07:00 Anil : > HI, > > I have atta