Re: Need IgniteConfiguration and XML at the same time? IgniteStormStreamer?

2018-09-05 Thread Saikat Maitra
Hello, 1. I think the issue with Incompatible class error is due to backward incompatible changes between slf4j-api 1.7.25 and ignite-log4j. I agree for most cases we need not worry on the dependency compatibility but incase of incompatible changes excluding dependencies helps. 2. The link I

RE: Batch insert into ignite using jdbc thin driver taking long time

2018-09-05 Thread Sriveena Mattaparthi
Hi Ilya, Can we cobimbe both of them together I mean 1. SET STREAMING ON; 2. JDBC thin driver batch insert (pstmt.executeBatch()) Thanks & Regards, Sriveena From: Ilya Kasnacheev [mailto:ilya.kasnach...@gmail.com] Sent: Wednesday, September 05, 2018 7:02 PM To: user@ignite.apache.org

Connection reset by peer

2018-09-05 Thread Jeff Jiao
Hi guys, we are using Ignite 2.3.0 we have a Ignite cluster in production which has 4 server nodes, recently we found that Ignite throws "Connection reset by peer" occasionally after some complex query, we know it is caused by connection closed while socket reading/writing, but why it closed?

how does Ignite Client restart ContinuousQuery when Ignite cluster failed and restart

2018-09-05 Thread Hansen Qin
I have 2 ignite cluster nodes on 2 AWS servers,both starting as server model.In my client,I use ContinuousQuery to listen to the Ignite events that i config and update my local cache data when event happens. I meet a problem when using this way to synchronize my local cache with ignite

AWS Cluster

2018-09-05 Thread im281
I am having hard time connecting to a 2 node cluster on an AWS deployment. I created two EC2 instances that I would like to 1) have discover each other 2) Connect via a .NET client I have followed the following instructions to create EC2 instances

Querying IgniteCache returns nothing when value class is located in a different package

2018-09-05 Thread max8795
Hello, I ran into an issue where querying the IgniteCache returns nothing if the class is located in a different package than where I'm initializing the cache and running the query. For example, let's say I have the cache IgniteCache inside my IgniteCacheConnector.java class and my package

Re: Igniter TCPDiscovery

2018-09-05 Thread akurbanov
Hello, I would recommend you to use org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder for this needs. Is there any specific reason for binding server node to loopback address? Another option is to define different multicastGroup for your current implementation and get rid of

Igniter TCPDiscovery

2018-09-05 Thread Skollur
I have two independent machines where ignite server node is running. i.e ,193.169.15.50 and ,193.169.15.51. Both are running with two different versions of cache. However when i tried to load the data to cache(i.e ,193.169.15.50) from one of these machine, it always finds another machine (i.e

Re: Loading Cache

2018-09-05 Thread Skollur
Thank you for reply. Is there example can you provide to load the data with criteria i.e load data (select query) is based on date range is restricted. i.e cache.loadcache(select * from table name where date = '02/02/108'). -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: configuration for some persistent and some non-persistent caches

2018-09-05 Thread Вячеслав Коптилин
I meant `datastore` cache of course ) Thanks, S. ср, 5 сент. 2018 г. в 19:04, Вячеслав Коптилин : > Hello, > > I just tried the configuration, you provided, and it works as expected. > I mean that only `datasource` cache persists its own data. > Please make sure you clean up working directory

Re: configuration for some persistent and some non-persistent caches

2018-09-05 Thread Вячеслав Коптилин
Hello, I just tried the configuration, you provided, and it works as expected. I mean that only `datasource` cache persists its own data. Please make sure you clean up working directory before testing. Thanks, S. вс, 2 сент. 2018 г. в 11:50, joseheitor : > Hi Denis, > > I am struggling to get

Re: Difference between replicated and local cache mode regarding time execution of query

2018-09-05 Thread ilya.kasnacheev
Hello! Unfortunately I'm not aware why you see such a big difference in this case. It should be comparable. Maybe SQL people will chime in? Regards, -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Execute IgniteRunnable in all Ignite nodes?

2018-09-05 Thread Lokesh Sharma
Many thanks! On Wed, Sep 5, 2018, 8:08 PM Ilya Kasnacheev wrote: > Hello! > > ignite.compute().broadcast() should do. > > Regards, > -- > Ilya Kasnacheev > > > ср, 5 сент. 2018 г. в 17:31, Lokesh Sharma : > >> During some events I want to run a piece of code at all nodes of Ignite. >> Is it

Re: Execute IgniteRunnable in all Ignite nodes?

2018-09-05 Thread Ilya Kasnacheev
Hello! ignite.compute().broadcast() should do. Regards, -- Ilya Kasnacheev ср, 5 сент. 2018 г. в 17:31, Lokesh Sharma : > During some events I want to run a piece of code at all nodes of Ignite. > Is it possible? I know, its possible to run a Runnable in exactly any one > of the nodes using

Execute IgniteRunnable in all Ignite nodes?

2018-09-05 Thread Lokesh Sharma
During some events I want to run a piece of code at all nodes of Ignite. Is it possible? I know, its possible to run a Runnable in exactly any one of the nodes using exec.submit(new IgniteRunnable() { @Override public void run() { System.out.println(">>> Printing '" + word + "' on

Re: Determine Node Health?

2018-09-05 Thread Chris Berry
Thanks to you both! -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Batch insert into ignite using jdbc thin driver taking long time

2018-09-05 Thread Ilya Kasnacheev
Hello! Have you tried streaming mode? https://apacheignite-sql.readme.io/docs/set Regards, -- Ilya Kasnacheev ср, 5 сент. 2018 г. в 15:44, Sriveena Mattaparthi < sriveena.mattapar...@ekaplus.com>: > Hi, > > > > I am trying to batch insert 30 records into ignite cache(on remote > server)

Re: Failed to activate node components

2018-09-05 Thread Ilya Kasnacheev
Hello! I had success with the following: IgniteSpringHelperImpl helper = new IgniteSpringHelperImpl(); ApplicationContext ctx = IgniteSpringHelperImpl.applicationContext( new File("config/POC5-server.xml").toURI().toURL()); Ignite ig =

Batch insert into ignite using jdbc thin driver taking long time

2018-09-05 Thread Sriveena Mattaparthi
Hi, I am trying to batch insert 30 records into ignite cache(on remote server) using jdbc thin driver. It is taking nearly 4mins to complete this operation. Please advise. Thanks & Regards, Sriveena "Confidentiality Notice: The contents of this email message and any attachments are

Re: Query 3x slower with index

2018-09-05 Thread Ilya Kasnacheev
Hello! I don't think that we're able to use index with IN () clauses. Please convert it into OR clauses. Please see https://apacheignite-sql.readme.io/docs/performance-and-debugging#section-sql-performance-and-usability-considerations Regards, -- Ilya Kasnacheev пн, 3 сент. 2018 г. в 12:46,

Re: How works an ignite node?

2018-09-05 Thread vgrigorev
according doc: https://apacheignite.readme.io/docs/job-scheduling#section-one-at-a-time where is described that Cores*4 number runs in parallel, Better, set this number: "parallelJobsNumber" value="16" by self to your number and check if it executed as described. You can parallelize to all

Re: error after activating cluster - Failed to wait for completion of partition map exchange

2018-09-05 Thread Ilya Kasnacheev
Hello! I think the prime issue is: Failed to activate node components [nodeId=41f041f2-01f8-4478-83b4-2cc6b7916205, client=false, topVer=AffinityTopologyVersion [topVer=1, minorTopVer=1]] class org.apache.ignite.IgniteException: Spring application context resource is not injected. which is

Re: How works an ignite node?

2018-09-05 Thread F.D.
Hi Eduard, I'm looking for maximum throughput , I thought so, but I found that I've the best performance with the same number of ignite instance as the cores. I've more than 8000 distributed closures that I want to execute on my ignite node. At the beginning of the execution the CPU is at 100%

Re: How to use Affinity Function to Map a set of Keys to a particular node in a cluster?

2018-09-05 Thread krishd
Hello I have a similar requirement : Need particular AffinityKey related data to go to Partitions OF PREDEFINED NODES ONLY. For eg. a PersonCache with 5 partitions distributed across 3 nodes. The Person object has cityCode as AffinityKeyMapped. The Person objects can have any of these 4

Re: Determine Node Health?

2018-09-05 Thread vgrigorev
I would propose to make periodic call to all nodes one by one with some simple remote function. Measure time or each node responce, and if it is low for some node according to your needs, avoid using this node for some period. How to choose nodes for call, single or many: IgniteCompute

Re: Determine Node Health?

2018-09-05 Thread Alex Plehanov
Hello Chris, There is no such metric as "node is healthy" now, but each node provides a lot of low-level metrics such as CPU usage, memory usage, jobs execution/waiting time etc, which you can combine and define your own criteria of "healthy node". These metrics available cluster-wide and

Re: Need IgniteConfiguration and XML at the same time? IgniteStormStreamer?

2018-09-05 Thread monstereo
Here is the pom.xml -> pom2.xml Here is the node configuration -> node.xml -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Need IgniteConfiguration and XML at the same time? IgniteStormStreamer?

2018-09-05 Thread monstereo
I have many questions *1)* This issue really annoying me, here is the error:(occurs in storm project) *java.lang.IncompatibleClassChangeError: Implementing class at java.lang.ClassLoader.defineClass1(Native Method) ~[?:1.8.0_181]at

Re: Query execution too long even after providing index

2018-09-05 Thread Prasad Bhalerao
Hi Andrey, Can you please help me with this? I Thanks, Prasad On Tue, Sep 4, 2018 at 2:08 PM Prasad Bhalerao wrote: > > I tried changing SqlIndexMaxInlineSize to 32 byte and 100 byte using cache > config. > > ipContainerIpV4CacheCfg.setSqlIndexMaxInlineSize(32/100); > > But it did not improve