Re: Using @SpringResource & @SpringApplicationContextResource in IgniteCallable

Yes Ilya, it worked. Thank you! -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Using @SpringResource & @SpringApplicationContextResource in IgniteCallable

ce please refer the below code, Compute client <https://github.com/ashishb888/ignite-2.8-poc/tree/master/ignite-spring-resource-compute-client> Compute server <https://github.com/ashishb888/ignite-2.8-poc/tree/master/ignite-spring-resource> BR, Ashish -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Limit ignite-rest-http threads

Hi Vladimir, I want to limit those threads. I want to control the threads size for ignite-rest-http. BR, Ashish -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Limit ignite-rest-http threads

Hi Vladimir, I want to limit those threads. I want to control the threads size for ignite-rest-http. BR, Ashish -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Limit ignite-rest-http threads

Before adding ignite-rest-http to the application my thread count was around 65 ashish@LAPTOP-0CGC34A5:~$ top -H -p 1468 top - 20:41:37 up 19:10, 0 users, load average: 0.20, 0.16, 0.15 Threads: 64 total, 0 running, 64 sleeping, 0 stopped, 0 zombie After adding ignite-rest-http to the

Re: Using @SpringResource & @SpringApplicationContextResource in IgniteCallable

Hi Ilya, My bad I forgot to push the changes. Now I just pushed the changes so you can find the required details. BR, Ashish -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Using @SpringResource & @SpringApplicationContextResource in IgniteCallable

Awaiting response. If you anything else let me know BR, Ashish -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Using @SpringResource & @SpringApplicationContextResource in IgniteCallable

Hello Ilya, All actions happens in service package e.g. poc.ignite.service.ComputeService#main() Starting server: ignite-spring-resource$ java -jar target/*.jar Starting client: ignite-spring-resource-compute-client$ java -jar target/*.jar I have attached the logs ignite-spring-resource.log

Re: Using @SpringResource & @SpringApplicationContextResource in IgniteCallable

Thank you Ilya for the response. I have two application first one is the server and second one is client. Here <https://github.com/ashishb888/ignite-2.8-poc/tree/master/ignite-spring-resource> you can find the sever application code and here <https://github.com/ashishb888/ignite-2.8

Re: Using @SpringResource & @SpringApplicationContextResource in IgniteCallable

Please help -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Using @SpringResource & @SpringApplicationContextResource in IgniteCallable

static class ICCall implements IgniteCallable { private static final long serialVersionUID = 4278959731940740185L; @IgniteInstanceResource private Ignite ignite; @SpringResource(resourceName = "testService") private T

Re: Purging a partition

Thank you! Actually I do not use persistence, and all the data stored in the RAM. Do we have similar things for the data stored in the RAM? BR, Ashish -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Delete query results in application crash

I am performing a delete query on a cache which has large data. When query start application CPU utilization goes around 2000, and application crashes with below error message, 2020-09-30 11:21:31.682 ERROR 128023 --- [grid-nio-worker-tcp-comm-5-#68%TcpCommunicationSpi%] ROOT

Purging a partition

Is is possible to purge a Ignite partition? If yes, how can we achieve? and will it advisable to do so? BR, Ashish -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

CacheVersionIO.read and AbstractDataPageIO.readPayload are hot methods

I am not able to understand why below methods are hot methods in my application. And I do not use persistence for my application yet. - org.apache.ignite.internal.processors.cache.persistence.tree.io - org.apache.ignite.internal.processors.cache.persistence.tree.io.CacheVersionIO.read(long, bool

Size of an object in Ignite cache

How one can know the exact size of an object stored on Ignite cache? Can we use below to get the size? byte[] arr = ignite.configuration().getMarshaller().marshal(new Person(10L, "first", "last")); -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Ignite transactions

Thanks guys for response -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Ignite transactions

For below code snippet, if exception occurs do I need to rollback the transaction? Or closing the transaction takes care of it? try (Transaction tx = transactions.txStart()) { Integer hello = cache.get("Hello"); if (hello == 1) cache.put("Hello", 11); cache.put("World", 2

Re: Ignite AtomicLong

Yeah, it is hard to say anything on above. What else do you need? Will provide you the information. Just wanted to understand what happened here. BR, Ashish -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Ignite AtomicLong

Thank you Ilya. I asked above because I got the below exception: org.apache.ignite.transactions.TransactionRollbackException: Failed to finish transaction because it has been rolled back [timeout=0, tx=GridNearTxLocal[xid=dec3274ff61--0b6f-279c--000a, xidVersion=GridCacheVersio

Ignite AtomicLong

How does AtomicLong work? Does it throws TransactionRollbackException? BR, Ashish -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Ignite swap space

Thank you Evgenii! I can understand that enabling swap may decrease the performance. Keeping in that mind I wanted to see what actually happens after enabling swap. For that I need to know how to enable swap on a specific node without affecting other nodes in the cluster. BR, Ashish -- Sent fr

Re: Affinity key & data rebalancing

As expected. Thank you Ilya for response. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Ignite swap space

I have, -4 nodes 2 clients & 2 severs. A & B are the clients and X & Y are the servers. -32 GB RAM -2 data regions default & xyz -A & B takes 2 GB RAM each. X takes 10 GB & Y takes 15 GB but may grow to 25 GB -X uses default region and Y uses xyz region All the above nodes run

Affinity key & data rebalancing

We have defined an affinity key e.g. someId for a cache. This affinity key will be linked to a partition of the cache. Now this partition is held by 1 node. In case the data for the partition grows more than that node limit, then what will happen? BR, Ashish -- Sent from: http://apache-ignite-u

Re: Failed to reinitialize local partitions (rebalancing will be stopped)

Hello Ilya, Okay, will file a ticket. BR Ashish -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Failed to reinitialize local partitions (rebalancing will be stopped)

Yes, I cleared the directories. Case 1: Exception occurs worker node and the node get killed Steps: -start data node -worker node -start data node -activate the cluster by client node (or by control script) Case 2: All nodes comes under baseline topology instead of 2 nodes (data

Re: Failed to reinitialize local partitions (rebalancing will be stopped)

Client node <https://github.com/ashishb888/ignite-poc/tree/master/ignite-persistence> Data node <https://github.com/ashishb888/ignite-poc/tree/master/ignite-persistence-data-node> Worker node <https://github.com/ashishb888/ignite-poc/tree/master/ignite-persistence-worker-node&

Ignite Persistence: Baseline Topology

I have a few queries: 1. There are 4 nodes. 2 of them with persistence enabled and rest with persistence disabled. And now I want to activate the cluster. Is it normal? Will it work? 2. There 2 nodes with persistence enabled. I have activated the cluster, and I am able to see two nodes in baselin

Re: Failed to reinitialize local partitions (rebalancing will be stopped)

Did anyone see the logs? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Failed to reinitialize local partitions (rebalancing will be stopped)

Please find logs here <https://gist.github.com/ashishb888/4afe60c681befd0e167ee280d3625521> -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Failed to reinitialize local partitions (rebalancing will be stopped)

I have three server node. Two of them with data-node attribute and remaining one with worker-node attribute. Persistence is enabled on data-nodes. When I try to activate the cluster I get bellow exception on worker node: 2019-12-27 18:22:58.181 ERROR 178084 --- [nge-worker-#103] .c.d.d.p.GridDhtPa

Re: Caused by: org.apache.ignite.IgniteCheckedException: Requested DataRegion is not configured: Data_Region

As of now will go with workaround. Thank you Ilya! -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Caused by: org.apache.ignite.IgniteCheckedException: Requested DataRegion is not configured: Data_Region

Removing dataStorageConfiguration entirely from client node worked. If we needed to keep dataStorageConfiguration on client node for some reason, then? BR, Ashish -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Caused by: org.apache.ignite.IgniteCheckedException: Requested DataRegion is not configured: Data_Region

Server node: -2 instances -Used for data storage -URL: https://github.com/ashishb888/ignite-poc/tree/master/ignite-persistence-data-node Client node: -1 instances -Used just for creating caches -URL: https://github.com/ashishb888/ignite-poc/tree/master/ignite-persistence

Re: Caused by: org.apache.ignite.IgniteCheckedException: Requested DataRegion is not configured: Data_Region

Do you want Github URL? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Caused by: org.apache.ignite.IgniteCheckedException: Requested DataRegion is not configured: Data_Region

2019-12-26 18:19:43.672 INFO 157980 --- [ent-worker-#101] o.a.i.i.m.d.GridDiscoveryManager : Data Regions Configured: 2019-12-26 18:19:43.673 INFO 157980 --- [ent-worker-#101] o.a.i.i.m.d.GridDiscoveryManager : ^-- Default_Region [initSize=256.0 MiB, maxSize=256.0 MiB, persisten

Re: Caused by: org.apache.ignite.IgniteCheckedException: Requested DataRegion is not configured: Data_Region

If I replaced *ignite.addCacheConfiguration(personCacheConfig);* with *ignite.configuration().setCacheConfiguration(personCacheConfig);*, then caches are created with no exception. But the caches do not provide table definition, no tables appears in sqlline. -- Sent from: http://apache-ignite-

Re: Caused by: org.apache.ignite.IgniteCheckedException: Requested DataRegion is not configured: Data_Region

Quotes are there I just removed them by mistakenly while pasting here -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Caused by: org.apache.ignite.IgniteCheckedException: Requested DataRegion is not configured: Data_Region

*Server node configuration* DataStorageConfiguration storageCfg = new DataStorageConfiguration(); DataRegionConfiguration defaultRegion = new DataRegionConfiguration(); defaultRegion.setName("Default_Region"); storageCfg.setDefaultDataRegionConfiguration(defaultRegion); DataRegionConfiguration da

Caused by: org.apache.ignite.IgniteCheckedException: Requested DataRegion is not configured: Data_Region

I have two server nodes and a client node. I have configured two data regions namely Default_Region and Data_Region on server nodes. I am trying to create caches from client node with: *cacheConfig.setDataRegionName(regionName);* where regionName is Default_Region or Data_Region. I am getting bel

ByteArrayConverter is not compatible with objects of type class org.apache.ignite.internal.binary.BinaryObjectImpl

I am using Ignite Kafka connector with below config: *connect-standalone.properties* key.converter.schemas.enable=false value.converter.schemas.enable=false key.converter=org.apache.kafka.connect.converters.ByteArrayConverter value.converter=org.apache.kafka.connect.converters.ByteArrayConverter

Re: Manage offset of KafkaStreamer

Noted. Thank you Andrei. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Ignite Kafka Connector

Can we query to the caches (that are created/loaded from Ignite sink connector) from the sqlline? I have observed that Ignite source connector create a topic with topicPrefix+SQL+SCHEMA+CACHE_NAME. Do we have control over this? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Standby nodes

We have 4 nodes (with attribute data-node) which are used for data storage. What we want is to have an additional node (with attribute data-node) and do not use it until one of the node (among the 4 nodes) goes down. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Standby nodes

Can we put some nodes on standby in Ignite? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Manage offset of KafkaStreamer

I want to start from a specific offset of the Kafka partition, it is possible with KafkaStreamer? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Kafka to Ignite

What are better ways to stream data from Kafka to Ignite cache? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Ignite on-heap & off-heap caches

Thank you Andrei. So for on-heap cache I need set Xms and -Xmx option to allocate the memory. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Ignite on-heap & off-heap caches

I have below question: Do both on-heap & off-heap caches use memory from data regions (by setting initial & max of DataRegionConfiguration)? Does Ignite use heap provided to the application (-Xms & -Xmx) for cache storage? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Actual size of Ignite caches

Yes I am talking about physical size in bytes. How to get it? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Actual size of Ignite caches

How to get the actual size of caches? And do Ignite cache use heap size provided to the application at the time of starting? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: SQLLine: Insert into for complex object not working

INSERT INTO "SCHEMA".CACHE VALUES (101,31,11,null,'B','B','C','D'); // Inserted INSERT INTO "SCHEMA".CACHE VALUES (101,3,1,null,'B','B','C','D'); // Gave error First 3 fields are part of the key. Thanks -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

SQLLine: Insert into for complex object not working

I have a cache, with complex key (3 fields). I am able get/put from/to the cache. But when I insert records from SQLLine, the first record goes to the cache, but any subsequent insert fails by giving "Error: Duplicate key during INSERT (state=23000,code=0)". I created cache by CacheConfigurati

Re: Ignite services (Node singleton)

You are not understanding brother. *Single Node* I have a Java application, which has one Ignite Service (Node singleton). We start the application, deploy the service (start the processing). *Multi Nodes* Added a flag "deploy", if true deploy the service. We start the application 4 times with

Re: Ignite client connection issue "Cache doesn't exists ..." even though cache severs and caches are up and running.

Please provide the configuration (Ignite) of all applications. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Ignite services (Node singleton)

Same source code I have to use. I can set the node attributes. I can use system properties as a solution for this, but not able to convince myself. Do you have any other alternatives? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Index not getting applied

You can make good use of Index Hints. e.g. SELECT * FROM Person USE INDEX(index_age) WHERE salary > 15 AND age < 35; -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Cannot exchange messages between two nodes.

I am sorry, I am not able to get your question fully. But you should exchange messages between nodes via topics. It may possible, you sent a message and no subscriber was there to receive the message. Can you provide more details on this question? Thanks -- Sent from: http://apache-ignite-user

Re: Ignite Data streamer optimization

Sure. But in my case I can not do so. Any other options for single threads? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Ignite services (Node singleton)

In my case, -3 different servers -A node singleton service -18 Nodes (All Maven based) I start 17 nodes, and then last node (18th), which start the node singleton service on the cluster. I want service to use different files paths (depends on the servers) e.g. on server 1 use /server1/../.. etc I

Re: Difference between Ignite Kafka Streamer and Kafka consumer (2.0)

Thanks Alexey for detailed explanation. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Client for multiple clusters

Sure. Thanks Ilya! -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Client for multiple clusters

What would be the best way for an application (Ignite client) to connect to multiple clusters? For now, I can think of creating multiple Ignite client instances with different configuration for the application (within a single Java app). -- Sent from: http://apache-ignite-users.70518.x6.nabble

Re: Ignite cache: Serializable vs Externalizable

The object need to be pushed to Kafka as well. I mean it is not just limited to Ignite. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Ignite cache: Serializable vs Externalizable

Which is better among Serializable and Externalizable? I have experienced Externalizable is slower than Serializable. Can somebody help me with this? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Ignite Data streamer optimization

I am using below settings: allowOverwrite: false nodeParallelOperations: 1 autoFlushFrequency: 10 perNodeBufferSize: 500 My records size is around 2000 bytes. And see the "grid-data-loader-flusher" thread stats as below: Thread Count Average Longest Duration grid-data-load

Threads and their purposes

I have an application, which uses data streamers (4 streamers) to load data in caches (4 caches). I can see different threads and their count: 1. tcp-comm-worker 1 2. pub 16 3. sys 16 4. sys-stripe 17 5. utility 16 6. upd-ver-checker 1 7. ttl-cleanup-worker 1 8. tcp-disco-srvr 1 9. tcp-disco-sock-r