Re: Cache queries - Failed to run map query remotely

2017-11-23 Thread Alexey Popov
Hi daniels, Just change the type of sortField from Object to more specific type, for instance, to "Integer" one. @QuerySqlField(index = true) private Integer sortField; I am not sure if SQL engine should be able to somehow cast Object to compare with "1". Thank you, Alexey -

Re: Failed to accept TCP connection. java.net.SocketException: Too many open files

2017-11-23 Thread aMark
Thanks for your help. I will look into pointers suggested by you. Thanks, -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Unable to start Hadoop Accelerator with Persistence

2017-11-23 Thread Denis Magda
Alex, Totally agree with you that even if the use case is meaningless the platform has to show a meaningful exception. Don’t hesitate reporting usability issues like this immediately going forward: https://issues.apache.org/jira/browse/IGNITE-7009

Re: Unable to start Hadoop Accelerator with Persistence

2017-11-23 Thread Alexey Kukushkin
Hi, I had same issue when I played with Hadoop a month ago. Developers told me it did not make sense having both Hadoop and native persistence :) However I still think we have at least a usability issue here since the exception does not tell much. Please let me know if you really need both persist

Re: Failed to accept TCP connection. java.net.SocketException: Too many open files

2017-11-23 Thread slava.koptilin
Hi Ashish, > is there a way I can control the number of open file handle in Ignite ? > Or is there a way to control the bin file size ?* If I am not mistaken, there is no way to control the bin file size or number of open file handles. The one thing that can be changed is a number of partitions

Cache queries - Failed to run map query remotely

2017-11-23 Thread daniels
Hi , I am using cacheQuery. My model have one index field public class Model { .. . @QuerySqlField(index = true) private Object sortField; } this query works properly- cache.query(new SqlQuery<>(Model.class, "OR

Re: IgniteInterruptedException: Node is stopping

2017-11-23 Thread Hyma
Below is the corresponding code where ignite step was in hung state. logInfo("Populating the canonical name Cache on Ignite Nodes") val time = System.currentTimeMillis() companyVORDD.mapPartitions(x => { val kvs = x.map(comp => (comp.wcaId,comp)).toMap[String,CompanyVO].asJava

Sorting or ranking TextQuery?

2017-11-23 Thread zbyszek
Hello All,I am looking at the TextQuery feature of Ignite (2.2).I have read (https://manikandansubbu.wordpress.com/tag/lucene/) that Lucene "returns results ranked by either the relevance to the query or sorted by an arbitrary field such as a document’s last modified date".I also am aware that in I

Re: ComputeTask is including Nodes for ComputeJobs prematurely

2017-11-23 Thread Denis Mekhanikov
> Affinity is not affected by IgniteCompute. My mistake. > I get a hold of an IgniteCompute _before_ the Affinity is applied I'm not sure, what you are trying to say. Correct me, if I'm wrong, but you are trying to choose a node to run a compute task on, depending on where a needed key is stored (

Re: JDBC ResultSet get columns with table alias

2017-11-23 Thread Denis Mekhanikov
Hi! Column access by name is supported by Ignite. Can you provide more details about your issue? Project with reproducer would be great. At least let us know, what version of Ignite and JDBC driver (thin or client

Re: Node unable to join cluster

2017-11-23 Thread Denis Mekhanikov
Josephine, You should specify addresses in IP finder together with ports. So, it should be like that: String[] addresses = {“ 206.142.241.45:1510”}; Then discovery SPI will be able to find itself, and the node will start. Do you have nodes in your cluster, that are able to see each other locally?

JDBC ResultSet get columns with table alias

2017-11-23 Thread bits1983_25
I'm in the process of migrating my datastore from Oracle to Ignite for serving the data to one of the search microservice. I have migrated the data successfully, but upon accessing the data using Ignite JDBC API , I'm facing one difficulty. All our current JDBC call is fetching the data from the re

Unable to start Hadoop Accelerator with Persistence

2017-11-23 Thread Amol
I have installed apache-ignite-hadoop-2.3.0-bin on CDH and able start it successfully. But when I try to enable persistence providing the config file, it fails. and below is the log. Can I know how it can be corrected. [root@hdfc01gw01 ~]# echo $IGNITE_HOME /applocaldata/ce_project/apache_ignite

Re: Use @ServiceResource with property placeholder

2017-11-23 Thread Denis Mekhanikov
Hi Krzysztof! We don't have this capability right now. You can only specify name of a service in this annotation. You are able to use properties in XML config, because it is processed by Spring. But the code, that performs service injection, doesn't know anything about Spring. Ignite uses its own

Use @ServiceResource with property placeholder

2017-11-23 Thread Krzysztof Chmielewski
Hi all, is it possible to use @ServiceResource with service name from property placeholder? In my Ignite config.xml I'm already using values from properties file Thanks Krzysztof -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Cache size changes unexpectedly

2017-11-23 Thread Denis Mekhanikov
Biren, Apparently, this cache metric is broken. It only shows number of records, that are locally stored. Here is the ticket for it: IGNITE-6564 For now you can use IgniteCache#size() method instead. It's much less optimal, but shows correct val

RE: Node unable to join cluster

2017-11-23 Thread Josephine Barboza
Hi, Still getting this error. 2017-11-23 08:59:27 [tcp-disco-msg-worker-#3%nvIDNGB1%] ERROR TcpDiscoverySpi:495 - Failed to connect to next node [msg=TcpDiscoveryNodeAddedMessage [node=TcpDiscoveryNode [id=a11e7f8b-6d64-4620-a296-1a52fb253a48, addrs=[10.131.12.16], sockAddrs=[/10.131.12.16:15

Re: Register Contentious query quit slow

2017-11-23 Thread Denis Mekhanikov
You can see ephemeral ports in logs. They are dynamically allocated for client socket connections by OS. And firewalls know about such connections. You can read about them on ip(7) man page , ip_local_port_range section. It is also well explained here