Ignite REST

2017-07-14 Thread waterg
Hello there, does ignite REST supports batch calls? Thank you! Jessie -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Ignite-REST-tp14952.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.

回复:Weird index out bound Exception

2017-07-14 Thread Aaron
Thanks agura, so my data node model this cache is REPLICATED, how client suppose init the Cache configuration and get refer to the cache? if I init the client cache configuration as REPLICATED, it seem stuck there,  Thanks again for your time! RegardsAaron

Re: How does CacheStore persistence actually work?

2017-07-14 Thread Andrey Mashenkov
Hi, 1. Ignite doesn't cate about whether persistence operations are local or not. It fully relies on CacheStore implementation. 2. CacheStore classes should be in classpath on all nodes including client nodes. These classes are not delivered automatically. 3. Writing to store always happened on pr

Inserting Data From Spark to Ignite

2017-07-14 Thread limabean
Hoping to get some help on how to insert data from Spark to Ignite. The test cases in the build are too trivial to help. Here is Try 3: It fails with this error at the moment: diagnostics: User class threw exception: javax.cache.CacheException: class org.apache.ignite.internal.processors.query.Ign

CodecNotFoundException: [smallint <-> java.lang.Integer] with Cassandra

2017-07-14 Thread Roger Fischer (CW)
Hello, there seems to be a problem with mapping between Cassandra numerical types to Java types. I am using ver. 2.0.0#20170430-sha1:d4eef3c6. In Cassandra, the column is defined as "smallint". In the Java POJO, the field is defined as "Short" In the configuration (QueryEntity), the field is def

RE: Provide persistence settings inline for Cassandra KeyValuePersistenceSettings?

2017-07-14 Thread Roger Fischer (CW)
Thanks, Evgenii. A minor addition, the content needs to be CDATA, as the value element is of string type and does not allow nested content. Roger -Original Message- From: ezhuravlev [mailto:e.zhuravlev...@gmail.com] Sent: Thursday, July 13, 201

Re: Security in Ignite

2017-07-14 Thread Denis Magda
Hello, As Val told Apache Ignite doesn’t provide any security related functionality at the moment but rather some interfaces you can implement on your own. To get the security support you need to look at commercial products built on top of Ignite: https://docs.gridgain.com/docs/security-and-au

Re: Execute Custom function in H2 Console

2017-07-14 Thread afedotov
Hi, If you have defined a custom function according to the https://apacheignite.readme.io/docs/miscellaneous-features#section-custom-sql-functions then to use it from H2 console you need to prefix it with the schema name of the cache where you have registered your function, for example: *SELECT YO

Re: Possible starvation in striped pool

2017-07-14 Thread Andrey Mashenkov
Hi Alper, Stripe pool threads do message processing. In stacktrace, I see node can send message to other node due to network issue or node failure. Thread try to reconnect to the node during failure detection timeout. What Ignite version do you use? Would you please share full logs? On Fri, Jul

Re: sql query in case of cluster group

2017-07-14 Thread Andrey Mashenkov
I don't think it is ORDER BY issue. Are you sure you run queries locally and on different nodes? On Fri, Jul 14, 2017 at 3:52 PM, neerajbhatt wrote: > Hi Andrew > > Thanks for your inputs now we are not getting duplicate records as we are > now using different cache and ignite objects for each c

Re: Define Cache Size - Queries

2017-07-14 Thread afedotov
Hi, Probably configuring a memory region of the desired maximum size should help you. Please refer to https://apacheignite.readme.io/docs/page-memory#section-memory-regions https://apacheignite.readme.io/docs/page-memory#section-memory-policies Kind regards, Alex. On Fri, Jul 14, 2017 at 8:02 A

Re: apache ignite cassandra persistentStore for enum fields

2017-07-14 Thread Igor Rudyak
Hi, You can store enum field as a blob using Cassandra module for Ignite, but you should manually specify this in your persistence descriptor. Igor On Jul 14, 2017 12:25 AM, "babak" wrote: > hi, > > I have a model with enum field. I insert the model to the ignite cache and > the enum field is

Re: Security in Ignite

2017-07-14 Thread jayn
Hello, Sorry to reply to this old thread but being a data fabric and the most popular being data grid and data needs security in the first place, it would give a great boost if some basic plugin/security code is already provided to hook up quickly to an ldap server or DB. I was doing a POC on Igni

Re: Ignite DataStream Troughput

2017-07-14 Thread Mikhail Cherkasov
On Fri, Jul 14, 2017 at 6:54 PM, mimmo_c wrote: > Thank you for your quick reply. > > I will try to set the Streamer. Have you any suggestion for NodeBuffer > size? > unfortunately, I have no recommendations for this one, only experiments will help here, it will be great if you will share your r

Re: Ignite DataStream Troughput

2017-07-14 Thread mimmo_c
Thank you for your quick reply. I will try to set the Streamer. Have you any suggestion for NodeBuffer size? If we set big size Buffer and the stream doesn't fill, it streams out auntil then end? Thanks Mimmo -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Igni

Re: Implementing Read through with sql server

2017-07-14 Thread slava.koptilin
Hi bhavishyamathur, 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. SQL queries work over in-memory data only. So,

Re: Weird index out bound Exception

2017-07-14 Thread agura
Hi, I can't reproduce your case. But the issue could occur if you had a REPLICATED cache and after some time changed it to PARTITIONED and for example call to getOrCreateCache keeping old cache name. -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Weird-index-ou

Re: Ignite DataStream Troughput

2017-07-14 Thread Mikhail Cherkasov
Hi Mimmo, I think you should play with the following streamer parameters: public int perNodeBufferSize() public void perNodeParallelOperations(int parallelOps) dataStream has a buffer per Node, perNodeBufferSize defines how many items should be saved in buffer before send it to server node.

Ignite DataStream Troughput

2017-07-14 Thread mimmo_c
Hi, We're testing ignite DataStream troughput with a network of 1Gbps. If we send a big file with scp we have a throughput of 150 Mb/s. We have 1 Ignite Server and 1 Ignite Client on version 2.0, in Client we have an HashMap of 1Million Entry which we send into Server's cache. The Cache is config

Re: Re: Requested array size exceeds VM limit

2017-07-14 Thread Andrey Mashenkov
Hi Lucky, It is a bad practice to set JVM memory >= 32GB. Usually, you can get a performance degradation for heap > 10Gb due to heavy GC. Also it make no sense to have different Xms and Xmx params on server side as, JVM never revert back free memory to OS. >From ignite-2.x there is no need to hav

Re: sql query in case of cluster group

2017-07-14 Thread neerajbhatt
Hi Andrew Thanks for your inputs now we are not getting duplicate records as we are now using different cache and ignite objects for each compute. But for queries which have order by (sort by) clause we are getting exactly same result from all cluster groups(nodes). It looks in case of order by t

Weird index out bound Exception

2017-07-14 Thread aa...@tophold.com
Hi all, I trying to create a client only near Cache of product cache, but when start up it always how a IndexOutOfBoundsException, looks very weird , must some configuration missed. very appreciate your time and advice CacheConfiguration productCache = clientNearCache(500, 500, ProductEnt

Re: sql query in case of cluster group

2017-07-14 Thread Andrey Mashenkov
Here you use same cache object from all computes. >> cache.query(qry.setArgs(args.toArray()).setLocal(true)).getAll(); So, actually, you run query on same cache node from threads belongs to other nodes. This will not work in multi JVM env. Just keep in mind that your task\job object can be tran

Re: sql query in case of cluster group

2017-07-14 Thread neerajbhatt
Any update ?, Also we have data as back up as one. In case of back ups can we get duplicate result as we might be getting result from both master and slave -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/sql-query-in-case-of-cluster-group-tp14884p14903.html Sent

Possible starvation in striped pool

2017-07-14 Thread Alper Tekinalp
Hi. What does following log means: [WARN ] 2017-07-12 23:00:50.786 [grid-timeout-worker-#71%cache-server%] G - >>> Possible starvation in striped pool: sys-stripe-10-#11%cache-server% [Message closure [msg=GridIoMessage [plc=2, topic=TOPIC_CACHE, topicOrd=8, ordered=false, timeout=0, skipOnTimeou

Re: sql query in case of cluster group

2017-07-14 Thread neerajbhatt
--code is as below --all caches are partitioned --args[0] is type of query, args[1] is number of queries, args[2] is ip of cluster group (each node is a separate cluster group. group name is 'i-' --we are trying with different args[2] (cluster groups) and we are getting duplicate result. Web co

Re: Fields order in binary object.

2017-07-14 Thread adzyuba
Ok, i see it works. But i found in Ignite 2.0 code this note: /** * When set to {@code true} fields are written by BinaryMarshaller in sorted order. Otherwise * the natural order is used. * * @deprecated Should be removed in Apache Ignite 2.0. */ @Deprecated publi

Re: sql query in case of cluster group

2017-07-14 Thread Andrey Mashenkov
Hi, Sound weird. Query qry.setLocal(true) should return local query result. Would you please share a code? On Fri, Jul 14, 2017 at 11:04 AM, neerajbhatt wrote: > Hello All > > We have a requirement to set time out for each node so that we can get a > partial result , in case of a time out fro

Re: same cache cannot update twice in one transaction

2017-07-14 Thread Mikhail
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. Also transactional guarantees are fully supported only for key-base

Re: Ignite PlugingProvider

2017-07-14 Thread luqmanahmad
Thanks Dmitry that helps alot -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Ignite-PlugingProvider-tp14640p14887.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: wrong data from cluster nodes while using left join

2017-07-14 Thread afedotov
Hi, I don't quite understand your case, but with LEFT JOIN you will have results even if there is no matching id in B, that's why "FROM A.R as r LEFT JOIN B.I as T ON r.id = T.id" works. By default cross cache join will operate only on data available locally on each particular node. Probably th

Re: Ignite PlugingProvider

2017-07-14 Thread dkarachentsev
Hi Luqman, ExtensionRegistry is used by IgnitePluginProcessor to replace internal Ignite interface implementations, but it's only used for MessageFormatter, MessageFactory and IoPool (search usages for IgnitePluginProcessor#extensions). So if you do not want to use your own implementation for that

sql query in case of cluster group

2017-07-14 Thread neerajbhatt
Hello All We have a requirement to set time out for each node so that we can get a partial result , in case of a time out from a particular node. To solve this we have created a cluster group for each node and run compute ClusterGroup cg = cluster.forAttribute("ROLE", group); computes.add(ignite.

apache ignite cassandra persistentStore for enum fields

2017-07-14 Thread babak
hi, I have a model with enum field. I insert the model to the ignite cache and the enum field is inserted but when I persist the cache using cassandra database, in the cassandra table the enum field is ignored. how can I solve this problem? -- View this message in context: http://apache-ignit

Re: getting exception while running the odbc examples

2017-07-14 Thread Igor Sapego
Can you share a core dump? Best Regards, Igor On Fri, Jul 14, 2017 at 7:39 AM, Rahul.S wrote: > no i didn't > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/getting-exception-while-running-the- > odbc-examples-tp14755p14861.html > Sent from the Ap

Heap Memory Allocation

2017-07-14 Thread Gracelin Priya
Hi, I am starting gridgain using a java program as given below try { ignite = Ignition.start("/opt/GridGain/config/default-server.xml"); } catch (Exception ex) { ex.printStackTrace(); } The above program is executed using the below