Re: concurrency issues in entry processor

2021-05-18 Thread Данилов Семён
Hello! Ignite indeed has such optimizations but I don't see them enabled in your configuration so perhaps it's a bug. I still have trouble reproducing your issue, so could you please send a minimal reproducer? Kind regards, Semyon. 19.05.2021, 06:12, "Kamil Misuth" : > Hi Semyon, > > we are u

Re: concurrency issues in entry processor

2021-05-18 Thread Kamil Misuth
Hi Semyon, we are using Ignite 2.8.1. That being said, could Ignite really be using some behind the scenes optimization which allows for a value instance to be re-used between multiple EntryProcessor runs? Kamil On 5/17/21 11:45 AM, Данилов Семён wrote: I tried reproducing your issue but wi

Re: How to deal with data expiration time flexibly

2021-05-18 Thread Ilya Korol
Hi, afaik unfortunately there is no opportunity to implement custom ExpiryPolicy that will rely on cache entry value field for expiry calculation because there is no any hook for intercepting value during expiry policy creation or calls. But you can use a little hacky trick with cache proxy li

ignite read stale data from backup node

2021-05-18 Thread guetsxjm
Hi Ignites, I ran into in-consistency data issues on version 2.8.1. I have three nodes run as a cluster and the cache configuration as: CacheConfiguration cacheConfiguration = new CacheConfiguration<>(Balance.class.getSimpleName()); cacheConfiguration.setIndexedTypes(Strin

Re: CacheEntryProcessor ClassNotFoundException after 2.7.6 -> 2.10.0 Upgrade

2021-05-18 Thread ihalilaltun
what we expect here is that related cacheentryprocessors or any other class should be redeployed in SHARED mode and do the task it should be. - İbrahim Halil Altun Senior Software Engineer @ Segmentify -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: kafka-connect and apache-ignite

2021-05-18 Thread akorensh
The Ignite servers should be set in the discovery section. 127.0.0.1:49500..49520 see: https://ignite.apache.org/docs/latest/clustering/tcp-ip-discovery The

Re: kafka-connect and apache-ignite

2021-05-18 Thread shubhamshirur
Where I should mention which IPs can you please tell me ? I have kafka server on one of AWS instance and ignite on another instance. Can you help? http://www.springframework.org/schema/beans"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation=" htt

Re: kafka-connect and apache-ignite

2021-05-18 Thread shubhamshirur
Where I should mention which IPs can you please tell me ? I have kafka server on one of AWS instance and ignite on another instance. Can you help? http://www.springframework.org/schema/beans"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation=" htt

is custom StreamSingleTupleExtractor compulsory in kafka-ignite-sink connector?

2021-05-18 Thread shubhamshirur
Hi I don't how to create custom extractor. Is it compulsory to create SSTE every time? My data is simple String key and String value in the topic. Thank you -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/