Is there a QUEUE based messaging?

hi team, I'm looking for a queue based messaging, comparing to topic, i dont want all subscriber received the message but one of them. please kindly advise thank you -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Ignite -Option to close the open files

Hi, I don't think that it's possible just to close files. How many caches do you have? Evgenii вт, 21 апр. 2020 г. в 12:14, Sriveena Mattaparthi < sriveena.mattapar...@ekaplus.com>: > Hi, > > > > Ignite server in preproduction and production are going down with too many > open files error. > >

Re: joins

No. In this case, you would need to create an index on orgId yourself. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Best way to track if key was read more than X times?

Ok bu the event just tells me if the key was read correct? I need to keep a count of how many times each key was read globally. The other way I was thinking of doing it is by having a cache as Cache and then use cache.invoke(, new CounterEntryProcessor()) And then in the EntryProcessor...

Re: joins

Thanks Alex for the explanation. I guess, I will need to set the distributed join option to false, if the affinity is in action. But doesn't the primary keys result in indexes? If so, then the requirement for having an index should be satisfied, right? I am joining the two tables on the field,

Re: Best way to track if key was read more than X times?

Hi, You can use Events:https://apacheignite.readme.io/docs/events In Particular: EVT_CACHE_OBJECT_READ see: https://github.com/apache/ignite/blob/master/examples/src/main/java/org/apache/ignite/examples/events/EventsExample.java Here is an example: (modified localListen() fn in the above

Re: joins

Hi, You are doing a join between a PARTITIONED and REPLICATED caches with distributedJoin=true. In this case an index is required . If you look at the full log, it will tell you where to place the index. see: https://apacheignite-sql.readme.io/docs/distributed-joins#non-collocated-joins

Re: joins

Hi, You are doing a join between a PARTITIONED and REPLICATED caches with distributedJoin=true. In this case an index is required . If you look at the full log, it will tell you where to place the index. see: https://apacheignite-sql.readme.io/docs/distributed-joins#non-collocated-joins

Ignite -Option to close the open files

Hi, Ignite server in preproduction and production are going down with too many open files error. Caused by: java.nio.file.FileSystemException: /opt/apache-ignite-fabric-2.5.0-bin/work/db/node00-94e4310a-f450-4bbc-acfd-f84ab29a158c/cache-SQL_PUBLIC_x/part-185.bin: Too many open files Based on

Best way to track if key was read more than X times?

Hi I want to store a key/value and If that key has been accessed more than 3 times for example remove it. What is the best way to do this?

Re: JDBC Connection

I would advise using the thin JDBC driver that is more lightweight and supports all the latest capabilities of the SQL engine: https://apacheignite-sql.readme.io/docs/jdbc-driver With that driver, you need to switch the streaming on/off using the SET command:

Re: Unable to run several ContinuousQuery due to: Failed to unmarshal discovery data for component: CONTINUOUS_PROC

Why is the client needs to be serializable? Have you tried suggestion from this answer https://stackoverflow.com/questions/61293343/failed-to-unmarshal-discovery-data-for-component-continuous-proc-with-more-than/61318360#61318360 ? Evgenii вт, 21 апр. 2020 г. в 00:36, AlexBor : > Hi Denis, > >

SQL queries returning incorrect results during High Load on Ignite V2.7.6

I have a table in which during the performance runs, there are inserts happening in the beginning when the job starts, during the insertion time there are also parallel operations(GET/UPDATE queries) happening on that table. The Get operation also updates a value in column marking that record as

joins

Hi All, I have defined two caches/tables: person and org. They are defined via query entities, and both have the same key fields. I have set the affinity on both tables. When I try to join the two tables, I get the following message [Failed to prepare distributed join query. Join condition does

Re: JDBC Connection

Denis, I am setting streaming on in my JDBC connection URL, and I try to insert data. Here is the sequence: Connection conn = DriverManager.getConnection("jdbc:ignite:cfg:// *streaming=true*@file:///opt/ignite/config/config.xml"); PreparedStatement stmt = conn.prepareStatement( "INSERT INTO

Re: Ignite.net caching a item to specific machine

Thanks Pavel. I will look at code and get back on it... Regards Sudhir On Tuesday, April 21, 2020, Pavel Tupitsyn wrote: > I've prepared the example: > https://github.com/ptupitsyn/ignite-net-examples/tree/ > master/CacheNodeFilter > > We don't actually need to write any Java, because Ignite

Re: Regarding EVT_NODE_SEGMENTED event

Thanks Monal, What is the best way to generate a EVT_NODE_SEGMENTED event on the client side for testing the event handler ? ( I am able to generate this on server side. ) regards, Veena. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Unable to initiate IgniteContext in spark-shell

Hi I am trying to do a POC with apache ignite and spark for improving our spark application performance. I have a 10 node Dev cluster ( centos 7, HDP 3.1, spark 2.3.2 ). I have installed apache ignite (2.8.0) on 5 of those servers. The installation was smooth and all 5 nodes were live with

Is strong consistency supported in SQL mode?

Hi, I see according to this article: https://www.gridgain.com/resources/blog/apache-cassandra-vs-apache-ignite-strong-consistency-and-transactions that Apache Ignite has support for strong consistency. The code example listed by them uses key-values. Is this true even when running Ignite in SQL

Re: Unable to run several ContinuousQuery due to: Failed to unmarshal discovery data for component: CONTINUOUS_PROC

Hi Denis, Both servers are looking to the same server. Here are code samples: Server: public class IgniteServerCacheBootstrap { final static Logger logger = LoggerFactory.getLogger(IgniteCacheClient.class); public static void main(String[] args) throws IgniteCheckedException,

Subquery or Joins query not returning correct result Ignite V2.7.6

Hi All, I am using Apache Ignite V2.7.6 .Net client And Server. -Tables(*Company*,*CompanyTypes*) creating with QueryEntities at the time cache configuration. I have two model class.And both classes all properties are SQL Query fields

Subquery or Joins query not returning correct result Ignite V2.7.6

Hi All, I am using Apache Ignite V2.7.6 .Net client And Server. -Tables(*Company*,*CompanyTypes*) creating with QueryEntities at the time cache configuration. I have two model class.And both classes all properties are SQL Query fields