Re: GridTimeoutProcessor - Timeout has occurred - Too frequent messages

2019-03-08 Thread userx
Hi, Any thoughts on the same. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Re: TPS does not increase even though new server nodes added

2019-03-08 Thread javastuff....@gmail.com
Checkout below - java.lang.Thread.State: BLOCKED (on object monitor) at java.io.PrintStream.println(PrintStream.java:805) - waiting to lock <0x85d6d798> (a java.io.PrintStream) at

isolated cluster configuration

2019-03-08 Thread javastuff....@gmail.com
Hi, We have a requirement for 2 separate cache cluster isolated from each other. We have 2 separate configuration file and java program to initialize. We achieved it by using non-intersecting IP and Port for different cluster while using TCP discovery. However, we need to achieve the same

Re: Affinity aware version of ICompute.Apply() in Ignite C# client

2019-03-08 Thread Raymond Wilson
Thanks Pavel :) Sent from my iPhone On 8/03/2019, at 9:47 PM, Pavel Tupitsyn wrote: > - Is this a capability defined in the Java client but not yet available in the C# client? There is no such API in Java AFAIK > - If not, is the standard practice to include the argument into the compute

Re: Why does write behind require to enable write through?

2019-03-08 Thread relax ken
Thanks! Very helpful! That is all I wanted to know On Fri, 8 Mar 2019, 09:04 Павлухин Иван, wrote: > Hi, > > Ignite CacheConfiguration inherits setWriteThrough method from JCache > API [1]. Enabled writeThrough in JCache means that cache is backed by > some other storage to which writes are

Re: cache is moved to a read-only state

2019-03-08 Thread Aat
visor> cache -slp -c=marketData Lost partitions for cache: marketData (12) +=+ | Interval |Partitions| +=+ | 86-816 | 86, 115, 241, 469,

Re: cache is moved to a read-only state

2019-03-08 Thread Aat
from git : PartitionLossPolicy partLossPlc = grp.config().getPartitionLossPolicy(); if (grp.needsRecovery() && !recovery) { if (!read && (partLossPlc == READ_ONLY_SAFE || partLossPlc == READ_ONLY_ALL)) return new IgniteCheckedException("Failed to write to

Re: cache is moved to a read-only state

2019-03-08 Thread Aat
my MarketData services is splitted into four publishers : who put values in the same cache. Maybe Cache does not support concurrency write ? __ public class CacheConfig extends CacheConfiguration { setCacheMode(CacheMode.PARTITIONED); setGroupName("quotationFeed");

Re: Can I update specific field of a binaryobject

2019-03-08 Thread Justin Ji
Besides the question above, I have another question. If I use a composed key like this: public class DpKey implements Serializable { //key=devId + "_" + dpId private String key; @AffinityKeyMapped private String devId; //getter setter } Now I need to add records like this,

GridTimeoutProcessor - Timeout has occurred - Too frequent messages

2019-03-08 Thread userx
Hi team, I am using ignite 2.7 and started the ignite server nodes with following configuration igniteInstanceName=XXX pubPoolSize=16 svcPoolSize=4 callbackPoolSize=40 stripedPoolSize=8 sysPoolSize=32 mgmtPoolSize=4 igfsPoolSize=40 dataStreamerPoolSize=8 utilityCachePoolSize=40

Re: Why does write behind require to enable write through?

2019-03-08 Thread Павлухин Иван
Hi, Ignite CacheConfiguration inherits setWriteThrough method from JCache API [1]. Enabled writeThrough in JCache means that cache is backed by some other storage to which writes are propagated along with writes to to the cache. Unfortunately (or not?) JCache uses write-through term while Ignite

Re: Affinity aware version of ICompute.Apply() in Ignite C# client

2019-03-08 Thread Pavel Tupitsyn
> - Is this a capability defined in the Java client but not yet available in the C# client? There is no such API in Java AFAIK > - If not, is the standard practice to include the argument into the compute func state that is sent to the node to execute it? Yes Thanks, Pavel On Thu, Mar 7,

Can I update specific field of a binaryobject

2019-03-08 Thread BinaryTree
Hi Igniters - As far as I am known, igniteCache.put(K, V) will replace the value of K with V, but sometimes I just would like to update a specific field of V instead of the whole object. I know that I can update the specific field via igniteCache.query(SqlFieldsQuery), but

cache is moved to a read-only state

2019-03-08 Thread Aat
Hello, after 5 minutes i have this exception : 2541 javax.cache.CacheException: class org.apache.ignite.IgniteCheckedException: Failed to write to cache (cache is moved to a read-only state): marketData 2542 at