Re: Ignite : IgniteDataStreamer question about units/valid ranges for perNodeBufferSize, autoFlushFrequency

isabled. > * > * Automatic flush is disabled by default (default value is {@code 0}). > * > * @param autoFlushFreq Flush frequency or {@code 0} to disable > automatic flush. > * @see #flush() > */ > public void autoFlushFrequency(long autoFlushFreq); > > Is the freq in times/sec or every millis etc ? > > > -- Vladislav Pyatkov

Re: How to retrieve data from Collocated Cache with Simple Key

vironment as there can be huge number of >> hits. >> >> I understand that for fast retrieval `key-to-partition` mapping is done. >> But, In AffinityKey documentation, it's specified that hashcode and equals >> methods are implemented based on simple key. >> >> *

Re: Ignite Startup Failures

gt; changed > in the configuration. Kindly let me know your inputs on what could possibly > be wrong. > > > > -- > View this message in context: > http://apache-ignite-users.70518.x6.nabble.com/Ignite-Startup-Failures-tp5427.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Ignite : IgniteDataStreamer question about units/valid ranges for perNodeBufferSize, autoFlushFrequency

ttributes ? > > > On Monday, June 6, 2016 1:31 AM, M Singh <mans2si...@yahoo.com> wrote: > > > Thanks Vladislav for the clarification. > > > On Monday, June 6, 2016 12:45 AM, Vladislav Pyatkov <vldpyat...@gmail.com> > wrote: > > > Hello, > >

Re: How to retrieve data from Collocated Cache with Simple Key

Hello Jamal, I think so, It not possible, because data store in particular partition, which determine only by affinityKey. More useful case, when you are not know fullKey, use ScanQuery(1) or use cache iterator. (1): https://apacheignite.readme.io/docs/cache-queries On Jun 6, 2016 3:34 PM,

Re: Ignite Startup Failures

the configuration. Kindly let me know your inputs on what could > >> possibly > >> be wrong. > >> > >> > >> > >> -- > >> View this message in context: > >> > http://apache-ignite-users.70518.x6.nabble.com/Ignite-Startup-Failu

Re: ignite in-memory sql query performance issue

ache.withKeepBinary().query(qry).getAll(); > > It took 160ms to get all the objects (only two objects inside the list) > > > > it takes 1ms to get a querycursor object, like this: > > QueryCursor qc = cache.withKeepBinary().query(qry); > > But still need 160ms to put the objects into a list and return; > > > > Best regards, > > Kevin > > > > > > > -- Vladislav Pyatkov

Re: Affinity Key Mapping

Number of partition does not affect the performance of the transaction. In general changing the number of partitions is done to evenly distribute data over nodes. On Fri, May 27, 2016 at 12:06 PM, amitpa wrote: > Hey , many thanks for the quick and awesome response. I

Re: About benchmark and scalability testing

t; is strictly prohibited, and may be unlawful.If you have received this >> communication in error,please >> immediately notify the sender by return e-mail, and delete the original >> message and all copies from >> your system. Thank you. >> >> --- >> > > > > -- > > Best regards, > Alexei Scherbakov > -- Vladislav Pyatkov

Re: Two nodes in cluster

only > that > where client is executed (client initialize hot loading from postgresql). > > > > > > -- > View this message in context: > http://apache-ignite-users.70518.x6.nabble.com/Two-nodes-in-cluster-tp5204.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Two nodes in cluster

-05-26 8:46 GMT+02:00 Vladislav Pyatkov <vldpyat...@gmail.com>: > >> Hello, >> >> If I understand correctly, you want to load data from a database in >> PARTITIONED type cache. This case is well described here >> https://apacheignite.readme.io/docs/data-lo

Re: Required Spring jars for Configuration

Hello Kamal, I think you can rule out a, g, h and i. But I could be wrong, it should be checked. Simply remove jars from the assembly and try to run.

Re: write behind question

://apacheignite.readme.io/docs/sql-queries On Fri, May 27, 2016 at 10:13 AM, Vladislav Pyatkov <vldpyat...@gmail.com> wrote: > Hello, > > I think you need to use Ignite Cache.load Cache(). > See the article: https://apacheignite.readme.io/docs/data-loading > > On Fri, May 27, 2016 at

Re: write behind question

> > > > > Best regards, > > Kevin > -- Vladislav Pyatkov

Re: Affinity Key Mapping

Hello, >> From the example it doesnt appear that we can put it in different caches. Yes, from the example in Java is not clear, but see example on Scala. This should work well (in different caches), it clear from implementation. >> how does Ignite figure out colocation in that case? Ignite does

Re: clarification on how to start transactions only on servers

Hello, Ignite stores transaction data on one node using own CacheStore. >>You can disable saves from client if you enable write-behind semantics. How it is written in the above thread. Could you describe more detail what task you decide? The first thing that comes to mind: 1) Distributed

Re: More nodes spend more time

? On Wed, Jun 22, 2016 at 10:23 AM, Level D <724172...@qq.com> wrote: > Hi, > > I demand both read and write operations, so I chose partitioned mode > cache. > > When I increased my cluster by one node, I got slower reads. > > Is there any way to make it faster? > > > -- Vladislav Pyatkov

Re: More nodes spend more time

tinuous query in Cache1. After > the end, console will print the total time. > > When I increased my cluster from two nodes to three nodes, console > returned me a larger number. > > Is there something more you need to know? > -- Vladislav Pyatkov

Re: Change rest-http Java to JSON null transformation logic

Hello, Why do you want this, if you can save full compatibility using custom serializer for null value (ObjectMapper#setSerializerProvider)? On Thu, Jun 16, 2016 at 12:15 PM, Alexey Kuznetsov wrote: > Hi All! > > I'm working on migrating from outdated json-lib to

Re: Ignite client needs explicit CacheConfiguration for first time for GetCache

the > same process (mentioned above) is repeated. is this a bug or there's any > workaround available. > > > > -- > View this message in context: > http://apache-ignite-users.70518.x6.nabble.com/Ignite-client-needs-explicit-CacheConfiguration-for-first-time-for-GetCache-tp5768.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: More nodes spend more time

m-up before the code will otimizirovan" exactly > mean? > What shoulde I do about the warm-up? > > Er... > > Question is not that complicated.It's not about continuous query. > Can you explain why more nodes spend more time when I execute sql query in > partationed mode? > Theoretically more nodes should be faster? > > -- Vladislav Pyatkov

Re: Ignite performance improvements

dding > nodes. > > > > > > > -- > View this message in context: > http://apache-ignite-users.70518.x6.nabble.com/Ignite-performance-improvements-tp5623p5680.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: How to exit from Client JVM while using Apache Ignite as Data Grid ?

Hi vijayendra, I think you run one client node () wihout at last one server node. In that case client node be waiting for server node until it (server node) will not by added. When you start another node in server mode (), client will continue to work. If it not help you, please provide

Re: how to check whether server and client connected?

Hello Ravi, Why are you not using Ignite client () node for access to cluster? Client node special created for using as gateway: doesn't sores data and doesn't compute job by default. On Wed, Apr 13, 2016 at 6:01 PM, Ravi kumar Puri wrote: > How do i connect to

Re: How to set isolated Ignite Clusters by java API

tLocalPort(49100); > cfg2.setDiscoverySpi(discoverySpi2); > cfg2.setCommunicationSpi(commSpi2); > > Ignite ignite2 = Ignition.start(cfg2); > } > } > > > > -- > View this message in context: > http://apache-ignite-users.70518.x6.nabble.com/How-to-set-isolated-Ignite-Clusters-by-java-API-tp6221.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: How to control the data unbalance among all the server nodes?

html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Ignite Cluster node stopped

ogs.bz2> > > > > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Ignite-Cluster-node-stopped-tp6608p6917.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Ignite Cluster node stopped

to upgrade ignite from 1.6 to 1.7。 > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Ignite-Cluster-node-stopped-tp6608p6962.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Local node seems to be disconnected from topology (failure detection timeout is reached)

from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Node authentication using security credentials

st wanted to know your thoughts. > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Node-authentication-using-security- > credentials-tp6853p6976.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Getting exception in SQL Query JOINS

: > http://apache-ignite-users.70518.x6.nabble.com/Getting-exception-in-SQL-Query-JOINS-tp6674p6732.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Start node in remote server which needs authentication

6.nabble.com/Start-node-in-remote-server-which- > needs-authentication-tp6668p6760.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Is there any test case for disaster tolerance ?

e any test case for it ? if there is, can you provide it > to me ? > > and I also need to start and stop remote nodes, is there any tool > that we can use it to start or stop remote nodes ? > > thank you very much ! > > -- Vladislav Pyatkov

Re: Start node in remote server which needs authentication

e-users. > 70518.x6.nabble.com/Start-node-in-remote-server-which- > needs-authentication-tp6668p6762.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: What is the recommended/typical deployment/managing procedure for Ignite in production?

pical- > deployment-managing-procedure-for-Ignite-in-production-tp6747.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: LOOK THORUGH THIS ERROR

> 18.x6.nabble.com/LOOK-THORUGH-THIS-ERROR-tp6977p7023.html >> Sent from the Apache Ignite Users mailing list archive at Nabble.com. >> > > -- Vladislav Pyatkov

Re: Ignite Compute - Rebalance Scenario

Partitions, where a key stored, will nut be migrated during task executing. By java doc[1]: The data of the partition where affKey is stored will not be migrated from the target node while the job is executed. You not need to worried, data will be situated in the same node and will migrate

Re: IgniteDataStreamer can't wirte data to ignite cluster

export JVM_OPTS="-Xms5g -Xmx5g -Xmn2g -server -XX:-UseGCOverheadLimit > -XX:+AggressiveOpts -XX:MaxPermSize=256m -XX:+UseP > arNewGC -XX:+UseConcMarkSweepGC -XX:+UseTLAB" > > the srv.xml is > > > > > > > > > > > > > > value="PRIMARY_SYNC"/> > > > > > > > > > > > > > > > > > class="org.apache.ignite.configuration.IgniteConfiguration" > scope="singleton"> > > > > > > > > > > > > > > 10.0.0.1:47500..47520 > 10.0.0.2:47500..47520 > > > > > > > > > > > > > > > > > value="/data1/home/igni1.5/my/swp"/> > > > > > > > > > > > > > > -- Vladislav Pyatkov

Re: Fail to join topology and repeat join process

gt; Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Starting Datagrid servers as partitions on same machine

Now I am not sure, which one is correct, in fact if I change the > cacheMode="*Replicated*" , still the result is same, please provide, which > one is the correct, as I am confused about the internal design > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Starting-Datagrid-servers-as- > partitions-on-same-machine-tp6945.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Understanding data store and partitioning

message in context: > http://apache-ignite-users.70518.x6.nabble.com/Understanding-data-store-and-partitioning-tp6264.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Understanding data store and partitioning

itions will by relocated to new node (with all data in it). > > Thanks > > > > -- > View this message in context: > http://apache-ignite-users.70518.x6.nabble.com/Understanding-data-store-and-partitioning-tp6264p6272.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: How does AffinityKey mapped?

e any other way to achieve collocate using > @AffinityKeyMapped? > > > > -- > View this message in context: > http://apache-ignite-users.70518.x6.nabble.com/How-does-AffinityKey-mapped-tp6260p6275.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Expiry cache at a certain time

m expiry policy to expire cache > content at a certain time, e.g.: at 12:00 all the cache contents will be > expired and removed from the cache? > > Thanks. > > > Best regards, > fsapei -- Vladislav Pyatkov

Re: How to save a list of value (such as strings or numbers) in cache with write through enabled?

value="fieldnum"/> > > > > to build the default type mappings. > > > > How to do the same configuration with list of objects (such as strings)? > > > > Best regards, > > Kevin > -- Vladislav Pyatkov

Re: How to stop a IgniteService gracefully?

ing resource > cleanups inside *IgniteService.cancel(ServiceContext context)* method. > > *Ignition.ignite().services().cancel(serviceName);* > > But, it cancels the service from all the nodes. How to cancel a locally > running Ignite service gracefully? > > -- > Kamal > -- Vladislav Pyatkov

Re: How to stop a IgniteService gracefully?

gt;> Re-framing my question: >> >> - Is Service.cancel() method is not a appropriate place for resource >> cleanups on shutdown? >> - How to tell Ignite to move a clustered singleton service from one node >> to another with external scripts? >> >> -- Kama

Re: What is the recommended/typical deployment/managing procedure for Ignite in production?

8.x6.nabble.com/What-is-the-recommended-typical- > deployment-managing-procedure-for-Ignite-in-production-tp6747p6769.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Ignite logging and troubleshooting

e the different log file location? As well to setup the logging > details? > > Thank you. > > > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Ignite-logging-and-troubleshooting-tp6771.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Start node in remote server which needs authentication

users. > 70518.x6.nabble.com/Start-node-in-remote-server-which- > needs-authentication-tp6668p6770.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Start node in remote server which needs authentication

1) If your configuration is not contains IgniteConfiguration (not abstract) then ignite start will fail. 2) You must to put the key into JKS. I recommend use JAVA_HMOE/bin/keytool for creation JKS and generate key. The links keyStoreFilePath, trustStoreFilePath must point to jks. On Fri, Aug 5,

Re: Is there any test case for disaster tolerance ?

ur answer, and I want to know that how the developers of > ignite test disaster tolerance ? > > > -- 原始邮件 -- > *发件人:* "Vladislav Pyatkov";<vldpyat...@gmail.com>; > *发送时间:* 2016年8月4日(星期四) 晚上6:13 > *收件人:* "user"<

Re: Start node in remote server which needs authentication

code example or full configuration file and logs > from cluster nodes? > > On Thu, Aug 4, 2016 at 8:14 PM, chevy <[hidden email] > <http:///user/SendEmail.jtp?type=node=6775=0>> wrote: > >> So, what do you think that is going

Re: Rest-api: Creating service to read data from cache

a; > this.b = b; > this.c = c; > } > > } > > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Rest-api-Creating-service-to-read-data- > from-cache-tp6788.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: What does ignite-atomics-sys-cache do and how many backups should it set?

hat-does-ignite-atomics-sys-cache-do- > and-how-many-backups-should-it-set-tp6778.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Local node seems to be disconnected from topology (failure detection timeout is reached)

It look like as segmentation by the reasong pause of garbage collector. You need attentively look the article [1] and collect GC logs, if GC works with long pauses (around 10 seconds) try to tune JVM. If the issue persists, please provide GC log and Ignite log for analyze. [1]

Re: Start node in remote server which needs authentication

You can generate new certificate using keytool [1]. If you want to extract ssh certificate and insert it to JKS, look to the article [2]. [1] https://www.sslshopper.com/article-most-common-java-keytool-keystore-commands.html [2]

Re: Node authentication using security credentials

mething? > > Thanks! > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Node-authentication-using-security- > credentials-tp6853.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Ignite Cluster node stopped

t; intOrder=260, lastExchangeTime=1469676024755, loc=false, > ver=1.6.0#20160518-sha1:0b22c45b, isClient=true] > [22:03:38,159][WARNING][disco-event-worker-#144%null%][ > GridDiscoveryManager] > Node FAILED: TcpDiscoveryNode [id=bf64226a-7597-4bc8-866b-6d99c7e9f2aa, > addrs=[124.250.36.47, 127.0.0.1, 172.21.0.37, 33.33.33.1], > sockAddrs=[/33.33.33.1:0, /124.250.36.47:0, /172.21.0.37:0, /127.0.0.1:0, > /124.250.36.47:0, /172.21.0.37:0, /33.33.33.1:0], discPort=0, order=503, > intOrder=264, lastExchangeTime=1469698198271, loc=false, > ver=1.6.0#20160518-sha1:0b22c45b, isClient=true] > [22:03:38,561][INFO][Thread-117][GridCacheProcessor] Stopped cache: > bjdqAppRecommendingCache > [22:03:38,563][INFO][Thread-117][GridCacheProcessor] Stopped cache: > bjdqAppRecommendedCache > [22:03:38,564][INFO][Thread-117][GridCacheProcessor] Stopped cache: > yiCheAppRecommendingCache > [22:03:38,564][INFO][Thread-117][GridCacheProcessor] Stopped cache: > yiCheAppRecommendedCache > [22:03:38,565][INFO][Thread-117][GridCacheProcessor] Stopped cache: > idfaCache > [22:03:38,566][INFO][Thread-117][GridCacheProcessor] Stopped cache: > clickedArticleCache > [22:03:38,566][INFO][Thread-117][GridCacheProcessor] Stopped cache: > deviceCache > [22:03:38,567][INFO][Thread-117][GridCacheProcessor] Stopped cache: > ignite-marshaller-sys-cache > [22:03:38,567][INFO][Thread-117][GridCacheProcessor] Stopped cache: > ignite-sys-cache > [22:03:38,568][INFO][Thread-117][GridCacheProcessor] Stopped cache: > ignite-atomics-sys-cache > [22:03:38,571][INFO][Thread-117][GridDeploymentLocalStore] Removed > undeployed class: GridDeployment [ts=1469624393224, depMode=SHARED, > clsLdr=sun.misc.Launcher$AppClassLoader@18b4aac2, > clsLdrId=a1d707c2651-424ef276-c1b6-48b0-9ded-c6fca0997502, userVer=0, > loc=true, > sampleClsName=org.apache.ignite.internal.processors.cache.distributed.dht. > preloader.GridDhtPartitionFullMap, > pendingUndeploy=false, undeployed=true, usage=0] > [22:03:38,585][INFO][Thread-117][IgniteKernal] > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Ignite-Cluster-node-stopped-tp6608p6865.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: ignite client cannot connect problem

commSpi = new TcpCommunicationSpi(); > > > > commSpi.setSharedMemoryPort(-1); > > commSpi.setLocalPort(ThreadLocalRandom.current().nextInt(49530, > > 49550 + 1)); > > igniteCCF.setCommunicationSpi(commSpi); > > // create ignite instance > > ignite = Ignition.start(igniteCCF); > > > > Any configuration I should change? Or add? > > > > Best regards, > > Kevin > -- Vladislav Pyatkov

Re: IgniteException on starting node from Jar

config inside jar rather than pick it from $IGNITE_HOME? > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/IgniteException-on-starting- > node-from-Jar-tp6881p6883.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Rest-api: Creating service to read data from cache

; from-cache-tp6788p6844.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Ignite Cluster node stopped

t; Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Rest-api: Creating service to read data from cache

You can see the list of topics: [1] https://apacheignite.readme.io/docs/rest-api#get [2] https://apacheignite.readme.io/docs/rest-api#put On Mon, Aug 8, 2016 at 9:04 AM, Vladislav Pyatkov <vldpyat...@gmail.com> wrote: > Hello, > > Ignite REST API is predefined. > You can u

Re: Does Apache Ignite support clustering multiple Java clients?

hard to follow. > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Does-Apache-Ignite-support-clustering-multiple-Java- > clients-tp6720p6839.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Local node seems to be disconnected from topology (failure detection timeout is reached)

n context: http://apache-ignite-users. > 70518.x6.nabble.com/Local-node-seems-to-be-disconnected- > from-topology-failure-detection-timeout-is-reached-tp6797p6804.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Near Cache

> all nodes in near cache after first access) > 3. Want to keep limited entries in near cache to avoid huge heap size. > > Thanks, > --Sambhav > > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Near-Cache-tp7033p7035.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Fail to join topology and repeat join process

> -Jason > > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Fail-to-join-topology-and-repeat-join- > process-tp6987p7057.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Fail to join topology and repeat join process

://apache-ignite-users.70518.x6.nabble.com/file/ > n7092/serialization_error.txt> > > > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Fail-to-join-topology-and-repeat-join- > process-tp6987p7092.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: 答复: persist only on delete

when the cache is manually remove(cache will not change > anymore) by me. > > > > For this case, It is a good idea to implement persist logic in > delete/deleteAll method while write/writeAll do nothing? > > > > @Override > public void delete(Object o) > { > //do nothing, we never have this operation. > } > > > > > > Thanks > > Shawn > -- Vladislav Pyatkov

Re: Asynchronous jobs (not the scheduling)

ync event. > > somethingLike: > > ``` > ignite.compute().run(() -> someServiceRefSomehow.doSomethingAsync()); > ``` > > where > ``` > interface SomeService { > CompletableFuture doSomethingAsync(); > } > ``` > > Or even better: > > ``` > interface SomeSe

Re: Ignite java and xml configuration

Hi Anil, You can use configuration cache in xml with annotation query field. But you if you are use @SqlQueryField, then you should use CacheConfiguration#setIndexedTypes property instead of QueryEntity. On Fri, Jan 27, 2017 at 12:06 PM, Anil wrote: > Hi, > > we are using

Re: Node not starting and waiting for ever

> ^-- System thread pool [active=0, idle=0, qSize=0] > ^-- Outbound messages queue [size=0] > > > Thanks, > > Ranjit > > -- Vladislav Pyatkov Architect-Consultant "GridGain Rus" Llc. +7 963 716 68 99

Re: 答复: how to increase CPU utilization to increase compute performance

> > > > > > > On 18 Jan 2017, at 13:02, Shawn Du <shawn...@neulion.com.cn> wrote: > > > > Hi, > > > > I have a task to compute on ignite. My Service has 8 cores. I split the > task into more than 1K jobs and merge the result. > > From client see, the task run more than 3 seconds, and sometimes more than > 10 seconds. The ignite server load is very slow. > > I wonder to know how to increase the CPU utilization to increase the > performance? > > > > Thanks > > Shawn > > > -- Vladislav Pyatkov

Re: Failed to wait for initial partition map exchange

> -Jason > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Failed-to-wait-for-initial-partition- > map-exchange-tp6252p7153.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Failed to wait for initial partition map exchange

Also, try to get dump (using jstack) from the node, which adding to the topology. On Fri, Aug 19, 2016 at 3:39 PM, Vladislav Pyatkov <vldpyat...@gmail.com> wrote: > Jason, > > Please, add system property -DIGNITE_THREAD_DUMP_ON_EXCHANGE_TIMEOUT=true > and attach new logs. >

Re: Puzzled about JVM configuration

t; > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Puzzled-about-JVM-configuration-tp7091.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Howto setup a single-node, standalone Ignite?

e-node- > standalone-Ignite-tp7197.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Does IgniteDataStreamer support traffic control

or anything > like backpress(supported by storm)? > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Does-IgniteDataStreamer-support- > traffic-control-tp7210.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Local node seems to be disconnected from topology (failure detection timeout is reached)

e-ignite-users. > 70518.x6.nabble.com/Local-node-seems-to-be-disconnected- > from-topology-failure-detection-timeout-is-reached-tp6797p6802.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Does Apache Ignite support clustering multiple Java clients?

ould > proceed to write data simultaneously. > > Thanks. > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Does-Apache-Ignite-support-clustering-multiple-Java- > clients-tp6720.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Failed to wait for initial partition map exchange

wait-for-initial-partition- > map-exchange-tp6252p7171.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: asynchronized cache put cause cache get blocked problem

other data (keys, values). But due to the first step, > the cache is locked. * > > *All the get operations are queued and wait for async cache put operations > to complete. * > > *Is there any way I can call get method without async put blocking?* > > > > *Please see press log for details. * > > > > *Best regards,* > > *Kevin* > > > > > > > > > -- Vladislav Pyatkov

Re: Re: null exception about EntryProcessor

on about EntryProcessor > Hi, > > You need to make your EntryProcessor a static class, otherwise it captures > a reference to your enclosing class which causes the serialization > exception. > > 2016-08-24 17:54 GMT+03:00 Vladislav Pyatkov <vldpyat...@gmail.com>: > >&

Re: failureDetectionTimeout NotWritablePropertyException

r.zk. > TcpDiscoveryZookeeperIpFinder"> > value="ves-hx-40:2181,ves-hx-41:2181"/> > > > > > > > > class="org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi"> > > /> > > > > > > > > > > > > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/failureDetectionTimeout-NotWritablePropertyException- > tp7304.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: How to estimate offHeapMaxMemory?

Hello, Look at the thread http://apache-ignite-users.70518.x6.nabble.com/Reducing-On-Heap-Cache-Memory-Footprint-td3836.html I just want to add, which property offHeapMaxMemory is set for each node individually. On Thu, Aug 25, 2016 at 4:18 PM, ght230 wrote: > I am trying to

Re: IgniteCompute.broadcast() stuck

6.nabble.com/IgniteCompute-broadcast-stuck-tp7255p7286.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Simple connect to gridgain via java for taken data

ache affinity assignment mode different from local [locId8=3c48b04b, > locDelayAssign=true, rmtId8=4d888c0f, rmtLateAssign=false, > rmtAddrs=[os-sbt-oaabs-006.ca.sbrf.ru/10.116.144.202, /127.0.0.1]] > at > org.apache.ignite.internal.managers.discovery.GridDiscoveryManager. > checkAttributes(GridDiscoveryManager.java:1124) > at > org.apache.ignite.internal.managers.discovery.GridDiscoveryManager.start( > GridDiscoveryManager.java:701) > at > org.apache.ignite.internal.IgniteKernal.startManager( > IgniteKernal.java:1571) > ... 13 more > > How I can in simple way via java just connect to caches and get information > from them? > > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Simple-connect-to-gridgain-via-java- > for-taken-data-tp7539.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Simple connect to gridgain via java for taken data

teCheckedException: Failed to > >> start > >> manager: GridManagerAdapter [enabled=true, > >> name=org.apache.ignite.internal.managers.discovery. > GridDiscoveryManager] > >> at > >> org.apache.ignite.internal.IgniteKernal.startManager(

Re: question about TcpServer inside ServerImpl.java

for loop finish? * > > } > > *catch* (IOException e) { > > *if* (log.isDebugEnabled()) > > log.debug("Failed to bind to local port (will try > next port within range) " + > > "[port=" + port + ", localHost=" + spi.locHost > + ']'); > > > > onException("Failed to bind to local port. " + > > "[port=" + port + ", localHost=" + spi.locHost + > ']', e); > > } > > } > > > > > > Best Regards, > > Kevin > -- Vladislav Pyatkov

Re: is there a interface let client know the change of assignment(like topology version)?

gnment(like topology > version)? > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/is-there-a-interface-let-client-know- > the-change-of-assignment-like-topology-version-tp7444.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Combine SQL and Text Query

and resume like '%Hello%'" so that > it hits the lucene index? > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Combine-SQL-and-Text-Query-tp7455.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: IgniteClientDisconnectedException

Hi, The stack does not contain any information why client is disconnected. Could you please provide logs files from server nodes? About configure mechanism of kicking off slow client, you can look the article[1]. But turn off this is bad idea, because slow client can lead to memory leak on

Re: Can not find schema for object with compact footer

The solution available on Apache ignite master branch. On Wed, Aug 31, 2016 at 11:59 AM, Vladislav Pyatkov <vldpyat...@gmail.com> wrote: > Hi, > I assume the issue has solved around week ago. > Lock at the ticket https://issues.apache.org/jira/browse/IGNITE-3618 > Can you che

Re: Can not find schema for object with compact footer

id setWorkflow(WorkflowInstance workflow); > > void setTriggeredByIds(long[] triggeredByIds); > > void setTriggeredByComponent(String component); > > void setActionName(String actionName); > } > > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Can-not-find-schema-for-object-with- > compact-footer-tp7406p7426.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Resolve using DNS rather than a multi-cast ip address

use only by the person(s) addressed above and > may contain privileged and confidential information. Disclosure or use of > this message by any other person is strictly prohibited. If this message is > received in error, please notify the sender immediately and delete this > message. > -- Vladislav Pyatkov

Re: Increase Ignite instances can't increase the speed of compute

er by return e-mail, and delete the original > message and all copies from > your system. Thank you. > -------- > --- > -- Vladislav Pyatkov

Re: Clearing a distributed queue hangs after taking down one node

> Thanks again. > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Clearing-a-distributed-queue-hangs- > after-taking-down-one-node-tp7353p7441.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

Re: Cache Problems

; > } > @Override > public Map map(List > subgrid, String arg1) throws IgniteException { > Map<ComputeJob, ClusterNode> map = new HashMap<>(lstSql.size()); > Iterator it = subgrid.iterator(); > for (final String sql : lstSql) { > if (!it.hasNext()) > it = subgrid.iterator(); > ClusterNode node = it.next(); > map.put(new ComputeJobAdapter() { > @Override public Object execute() { > doLoadData(sql); > return 1; > } > }, node); > } > return map; > } > @Override > public Integer reduce(List results) throws > IgniteException { > int sum = 0; > for (ComputeJobResult res : results) > sum += res.getData(); > return sum; > } > private void doLoadData(String sql){ > LogPrint.LOADER_BASE_INFO_LOGGER.info("DataLoaderTaskAdapter > started ,cacheName:" + cacheName + ",sql:" + sql); > IgniteCache cache = ignitePublicService.getCache(cacheName); > long startTime = new Date().getTime(); > cache.loadCache(null, loadKey, sql); > LogPrint.LOADER_BASE_INFO_LOGGER.info("load cache use time:" + > (new Date().getTime() - startTime) + "ms, size=" + > cache.size()+",cacheName="+cacheName + ",sql:" + sql); > } > } > > By the way, does ignite proide an API to release off-heap memory? Is there > an offHeapMaxMemory property which can rule all caches within an ignite > instance instead of one cache in an ignite instance? > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/Cache-Problems-tp7477p7592.html > > -- Vladislav Pyatkov

Re: Nested Transactions

http://apache-ignite-users. > 70518.x6.nabble.com/Nested-Transactions-tp7662p7702.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov

  1   2   3   >