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

Hi, How many MatchingJobs do you submit? On Tue, Sep 13, 2016 at 12:29 PM, 胡永亮/Bob wrote: > Hello, Vladislav > > The following is some code. > > ... > IgniteCompute compute = ignite.compute();//.withAsync(); > > compute.run(new MatchingJob(m_mapReadyDataPara)); > } > > pr

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

Hello, Vladislav The following is some code. ... IgniteCompute compute = ignite.compute();//.withAsync(); compute.run(new MatchingJob(m_mapReadyDataPara)); } private static class MatchingJob implements IgniteRunnable{ private Map> m_mapReadyData; priva

Re: persistent store

Hi val, Thank you for your response. I mean 'stream file' is a linux regular file, in which a pojo can be stored. I loaded 200,000 Person objects from MariaDB. This was fast. After load, I deleted all object in MariaDB via 'delete from Person' I modefied the salary value from example and tried to

Re: Ignite Thread count

Hi Peter, I don't really know your use case :) From my experience, default Ignite settings with combination of JVM setting provided in docs give the best performance for most use cases. However, you're changing these settings for a different reason and don't know how it will influence the results.

Ignitevisorcmd can not connect to the cluster

I often use ignitevisorcmd to connect the cluster in order to watch the cache, but sometimes it fails, especially just after one slow client disconnected by the cluster. below is the info about the ignitevisorcmd. [10:32:08,149][INFO][main][TcpCommunicationSpi] Successfully bound shared memory co

Re: Nested Transactions

Hi, Please properly subscribe to the mailing list so that the community can receive email notifications for your messages. To subscribe, send empty email to user-subscr...@ignite.apache.org and follow simple instructions in the reply. akaptsan wrote > Is there any chance Ignite will support setS

Re: Couchbase as persistent store

Hi Kevin, It looks like you serialize the instance of the CacheStore, most likely due to the fact that you use SingletonFactory. Please try to use ClassFactory or your own factory that will not encapsulate the instance, but will create a new one in the 'create()' method. -Val -- View this mess

Re: Query does not include objects added into Cache from within a transaction

Hi, SQL queries are currently not transactional. There is a ticket for this improvement: https://ggsystems.atlassian.net/browse/IGN-4666 -Val -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Query-does-not-include-objects-added-into-Cache-from-within-a-transacti

Re: persistent store

Hi, You can use anything as persistent store as long as it can be implemented within the CacheStore implementation. Can you clarify what you mean by 'stream files'? As for performance, please provide more details. What and how are you measuring? What is your configuration? How do you update the c

Re: Autonomous transaction

Hi, Please properly subscribe to the mailing list so that the community can receive email notifications for your messages. To subscribe, send empty email to user-subscr...@ignite.apache.org and follow simple instructions in the reply. akaptsan wrote > Is it possible to perform autonomous transac

Re: Ignite cluster upgrades with zero downtime.

akaptsan wrote > Is there any limitations? E.g. would it be possible to perform rolling > upgrade from version 1.7 to 2.0? Hi, Major releases are generally backward incompatible, even in compile time. This most likely will be true for Ignite 2.0, so even having rolling upgrade functionality will

Re: Cache Problems

Hi, I have about 17GB data needs to be loaded into ignite. Every time I destory the cache and create the cache with the same name, the memory increases 17GB. It seems the off-heap memory not released. I find ignite can release off-heap memory when grid stopped. I'd like to know if ignite can

Service grid client need service implementation deployed locally

Hi, I have tried to use service grid funtionality with one ignite server node and one ignite client node(clientMode=true) . After some simple tests i found that the client errored out without the service implementation calsses deployed locally (xximpl.class not found ). When implementation classes

Question about DisableExplicitGC

I have read the aticle about jvm and system tuning (https://apacheignite.readme.io/docs/jvm-and-system-tuning#section-detailed-garbage-collection-stats). Below are sets of advanced JVM configurations for applications that might generate high numbers of temporary objects hence triggering long pau

Re: Automatic Persistence Example - Demo

Thanks Denis for your quick response. Our requirement is to make it work in the linux command line. The method mentioned in the Automatic Persistence page, is to import the pom.xml from the IDE and execute the Demo.java. With Eclipse in Windows is working. To take it to the next step I am trying to

Re: Automatic Persistence Example - Demo

Alternatively, you can follow this guide [1] that relies on ignite-schema-import.sh script that does all the work for you. [1] https://apacheignite.readme.io/docs/automatic-persistence#demo — Denis > On Sep 12, 2016, at 2:58 PM,

Re: Automatic Persistence Example - Demo

Hi, You need to add all the libs that are located in “apache-version/libs” folder to your classpath. — Denis > On Sep 12, 2016, at 2:46 PM, Abhishek Jain > wrote: > > Hi, > > Not able to execute the Demo example given in the Automatic Persistence from > the command line in linux. Below is

Automatic Persistence Example - Demo

Hi, Not able to execute the Demo example given in the Automatic Persistence from the command line in linux. Below is the console output, please let me know if I am missing out anything. I tried couple of ways below with NO success === [root

Re: Cache Problems

Hello, I got configuration cache like in your sample. I was destroying and creating cache and tracked consume of memory by java process, but have not saw growth of physics memory. I conclude, that that is not a memory leak in Ignite. Please provide full example, where are you seen memory leak. I

Re: Trouble with Using Ignite 1.8 ODBC Driver

Hey, Igor many thanks. Is it possible for you to let you know the branch? If it is available in github, I can manually merge in master and try ( We need it urgently). Regards -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Trouble-with-Using-Ignite-1-8-ODBC-Dri

Re: How off heap works

Yes, LRU policy will be used for OFFHEAP_TIERED cache memeory mode. If you have 3gb/sec it is possible that it leads to allocation of big amount of object in heap. May be recomendations about JVM tuning recommendations will help you [1]. [1] https://apacheignite.readme.io/docs/jvm-and-system-tuni

Re: Trouble with Using Ignite 1.8 ODBC Driver

Hi, This is a known issue with the ODBC installer and it has already been fixed. It is going to be merged into master branch soon. Best Regards, Igor On Sat, Sep 10, 2016 at 3:28 PM, amitpa wrote: > Hi All, > > We are trying to use Ignite ODBC Driver with DSN. We could build it fine > and > i

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

Hello, I don't understand, what do you try to measure, without code. Size of calculation task, size of data moved into network have importance. Could you please provide code example? On Mon, Sep 12, 2016 at 12:33 PM, 胡永亮/Bob wrote: > Hi, everyone: > > I am using Ignite for computing and ca

Increase Ignite instances can't increase the speed of compute

Hi, everyone: I am using Ignite for computing and cache. I use the same input data and the same compute logic. When my ignite cluster's node is 2 in 2 machines, the total cost time is 38s. But, when I increase the Ignite cluster nodes to 3 in 3 machines, the cost time is 32s/51

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

Hello, I have not find unfair consumption of queue. I added simple modification into your case: *AtomicLong messageCounter = new AtomicLong();* *ExecutorService consumerThread = Executors.newSingleThreadExecutor();* *consumerThread.execute(() -> {* *while (true