How to set query timeout or cancel query when submit SQL query from SQL tool like DBweaver and sqlline?

2018-09-13 Thread Ray
When I go through this document https://apacheignite-sql.readme.io/docs/query-cancellation, it seems query can set timeout if the query submitted through java API(SqlQuery, SqlFieldsQuery). So my question is how to set query timeout or cancel query when submit SQL query from SQL tool like

Question about Caching, Console, and PeerClassLoading

2018-09-13 Thread KJQ
I have a question about how Caching, the Web Console, and Peer ClassLoading work... I have 2 nodes, both with PeerClassLoading enabled, and the web console started. From the caching side, it appears everything is working as it should (without peer class loading I seemed to get intermittent

Re: how to configure apache ignite as cache api and as spring cache provider

2018-09-13 Thread vkulichenko
Monil, You can also use IgniteSpringBean to initialize Ignite separately from SpringCacheManager, but within Spring context. So you need to configure following beans: 1. PercentageDataRespository 2. IgniteConfiguration 3. IgniteSpringBean (IgniteConfiguration is injected via 'configuration'

Can't connect VisualVM to Ignite 2.4, 2.6 process on windows

2018-09-13 Thread Alew
Hi! I was suggested to use VisualVM as a debugging tool but can't connect it to ignite process. I start bin/ignite.bat script and point visualvm to ignite process. After that I get default os window "java platform se binary has stopped working" Cmd console contains

Re: how to configure apache ignite as cache api and as spring cache provider

2018-09-13 Thread mshah
Hi, So the issue here is in order to use Ignite as key-value Cache API along with Spring Repository we have to let the spring application context initialize fully and then need to start ignite instance passing the application context. In order to use Ignite as Spring Cache provider the

KafkaStreamer and IgniteDataStreamer dynamic cache name

2018-09-13 Thread kcheng.mvp
Seems KafkaStreamer and IgniteDataStreamer has one to one mapping. that's to say a KafkaStreamer can only persistent to one cache. right now my case is a bit complicated. KafkaStreamerGenericEntity*> kafkaStreamer = new KafkaStreamer<>(); during persist phrase, I need to save a *GenericEntity*

Re: how to configure apache ignite as cache api and as spring cache provider

2018-09-13 Thread KJQ
I dont know if this helps or not but we ran into a similar issue testing the distributed cache with Shiro authentication. Shiro was eagerly trying to create the cache but the Spring Ignite instance (inside the SpringCacheManager) had not yet been initialized (I believe it initializes after all

Re: how to configure apache ignite as cache api and as spring cache provider

2018-09-13 Thread mshah
Hi Val, Thank you for the response. I got the options you mentioned. I have still one more clarification required. I have configured Custom Cache Store which internally uses Spring Repository. Please check below code. public class PercentageModelStore extends CacheStoreAdapter {

Re: how to configure apache ignite as cache api and as spring cache provider

2018-09-13 Thread vkulichenko
You need to make sure Ignite is started *before* SpringCacheManager. Basically, you have two options: 1. Start Ignite manually using Ignition.start, and then start Spring app with SpringCacheManager that references already started Ignite via 'igniteInstanceName' property. 2. Incorporate

Re: .NET. Is where a way to get JVM metrics from dotnet?

2018-09-13 Thread Pavel Tupitsyn
Hi, Yes, regular java tools like jvisualvm work just fine with JVM started by Ignite.NET. On Thu, Sep 13, 2018 at 7:29 PM Ilya Kasnacheev wrote: > Hello! > > My recommendation is to take thread dump using jstack and heap dump using > jmap. > > I hope that they will happily operate on

Re: Unreasonable segmentation in Kubernetes on one node reboot

2018-09-13 Thread Kopilov
For some reason, Nabble has not displayed formatting, sorry, but it was displayed in preview. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Unreasonable segmentation in Kubernetes on one node reboot

2018-09-13 Thread Kopilov
Hello! I have made Java application with embedded Ignite and deployed it to Kubernetes by using StatefulSet with LivenessProbe. Application has three pods replicated per three physical nodes. As failover test, I reboot one Kubernetes node (it has pod with slave Ignite node). *While it is offline

Re: .NET. Is where a way to get JVM metrics from dotnet?

2018-09-13 Thread Ilya Kasnacheev
Hello! My recommendation is to take thread dump using jstack and heap dump using jmap. I hope that they will happily operate on JVM-containing process. Regards, -- Ilya Kasnacheev чт, 13 сент. 2018 г. в 19:25, Alew : > Hi! > > I get OOMEs and my current hypothesis is that there are too many

.NET. Is where a way to get JVM metrics from dotnet?

2018-09-13 Thread Alew
Hi! I get OOMEs and my current hypothesis is that there are too many threads in the Java part in the _thread_in_native state. To make a repro I need to get JVM metrics from dotnet. So I want to know how to do it. Thanks.

Re: Query execution too long even after providing index

2018-09-13 Thread ezhuravlev
Hi, What is the execution time of just a single query without UNION? Evgenii -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Ignite Visor cache not active

2018-09-13 Thread mshah
Hi, What is the correct way to start visor for the ingnite instance started from spring boot application. I started the ignite node from the spring boot application as below ApplicationContext context= SpringApplication.run(Application.class, args); Ignite

Re: ./control.sh --baseline doesn't list nodes on a linux machines

2018-09-13 Thread Alex Plehanov
There is also the bug (ticket [1]) related to daemon nodes (visor joins the cluster as a daemon node). Visor switches cluster to compatibility mode, in this mode baseline topology is not supported. You can read more details here: [2]. I think this bug can be related to your case too. Please

Re: Invoking instance of Ignite service which is deployed together with a cache data

2018-09-13 Thread Ilya Kasnacheev
Hello! My recommendation will be, roughly, ignite.compute().affinityRun(cacheNames, key, () -> ignite.services().service(serviceName).whateverInvocation()); Hope this helps, -- Ilya Kasnacheev чт, 13 сент. 2018 г. в 12:40, Maxim Malygin : > Hi Guys, > > I have a service (Ignite Service Grid)

Re: Error with Spark + IGFS (HDFS cache) through Hive

2018-09-13 Thread Maximiliano Patricio Méndez
Hi evgenii, thanks for answering. I'm fairly new to ignite, but from what I can see in the docs the ignite rdd or the ignite dataframe are only used to serve data that is already in Ignite in the form of a Table or cache. Unfortunately I currently have a couple hundred tables in HDFS referenced

Re: Node keeps crashing under load

2018-09-13 Thread Ilya Kasnacheev
Hello! I have filed this ticket: https://issues.apache.org/jira/browse/IGNITE-9586 Hope that it eventually get looked at by somebody in context. Regards, -- Ilya Kasnacheev ср, 12 сент. 2018 г. в 22:10, eugene miretsky : > Good question :) > yardstick does this, but not sure if it is a

Re: rest api question

2018-09-13 Thread Ilya Kasnacheev
Hello! In order to use HTTP REST API with non-primitive objects you will have to implement ConnectorMessageInterceptor in Java. Then you can hook it in Ignite Spring XML config.

rest api question

2018-09-13 Thread Som Som
Hi. What is a right way to add TestEntity(it has 2 fields) into the cache via REST API. This is how I created TestEntity cache: public class TestEntity { public string ValueString { get; set; } public DateTime ValueDateTime { get; set; } } class

Re: Ignite Cluster: Cache Misses happening for existing keys

2018-09-13 Thread Вячеслав Коптилин
Hi, You can try with using EntryProcessor. Please take a look at the following example: public class EntryUpdater implements EntryProcessor { @Override public String process(MutableEntry entry, Object... arguments) throws EntryProcessorException { if (!entry.exists()) {

Re: ./control.sh --baseline doesn't list nodes on a linux machines

2018-09-13 Thread es70
Alex, please note that I followed the cluster activation routine on a windows machine before doing the same on a linux and I succeded in activating the cluster -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: how to configure apache ignite as cache api and as spring cache provider

2018-09-13 Thread mshah
Hi, Thank you for the response. I tried the following configuration as you mentioned http://www.springframework.org/schema/beans; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance; xmlns:cache="http://www.springframework.org/schema/cache;

Re: ./control.sh --baseline doesn't list nodes on a linux machines

2018-09-13 Thread es70
Hi Alex Right! Missed to mentioned about activating the cluster. I did try to activate the cluster. I called ./control.sh --activate. Got the answer "Cluster activated". But the ./control.sh --baseline command still gave me an empty list. The top command said in the summary that Active = true

Re: ./control.sh --baseline doesn't list nodes on a linux machines

2018-09-13 Thread Alex Plehanov
Hello Eugene, Did you activate this cluster before? Baseline topology can be set explicitly (via control.sh script or Java API) or implicitly after the first activation. Currently, your cluster is not activated. If cluster never was activated before and you didn't set baseline topology

RE: Ignite Cluster: Cache Misses happening for existing keys

2018-09-13 Thread HEWA WIDANA GAMAGE, SUBASH
Thank you for the prompt response. I agree there’s a race condition here. But the problem of the suggestion is, “getNewValue()” will get called even for cache hits. This getNewValue eventually calling some backend legacy API and the caching layer is setup to reduce the load for it. From:

./control.sh --baseline doesn't list nodes on a linux machines

2018-09-13 Thread es70
I have a cluster of RHEL machines (3 in total) and run Ignite 2.6 on them. The nodes seem to see each other since the visor shows them in the TOP command so I want to join the nodes to a cluster. I run the ./control.sh

Re: Stupide question about Queue ?

2018-09-13 Thread Maxim.Pudov
Yes, this this functionality was presented in 2.1.1. Just turn on persistence by calling IgniteConfiguration cfg = new IgniteConfiguration(); cfg.setPersistentStoreConfiguration(new PersistentStoreConfiguration()); In 2.3.1 API has changed. Now it is required to enable persistence in a default

Re: Ignite RPM Installation As Service ignitevisorcmd usage

2018-09-13 Thread ilya.kasnacheev
Hello! Our current package build includes this script but it does not work out of FHS yet. This is left as an exercise for future releases. So if you need to use it, please download binary Apache Ignite release tarball and use this script from it. Thanks for telling us that you're using our

Invoking instance of Ignite service which is deployed together with a cache data

2018-09-13 Thread Maxim Malygin
Hi Guys, I have a service (Ignite Service Grid) which deploys on each node in cluster (one instance per node). The service has a method which reads data from a partitioned cache by a key which is passed as parameter of the method. I'd like to invoke an instance of the service which is deployed on

Re: a node fails and restarts in a cluster

2018-09-13 Thread es70
Thanks Pavel. Look forward to have it fixed -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: 答复: why my ignite cluster went to compatibility mode

2018-09-13 Thread ezhuravlev
Hi, >but why one of my ignite nodes went down abnormally? Can you share logs with the community so somebody could take a look into it? Evgenii -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Proper config for IGFS eviction

2018-09-13 Thread ezhuravlev
Hi, There are metaCacheCfg and dataCacheCfg in IgniteConfiguration.FileSystemConfiguration, which allows to configure caches for IGFS. Inside this configuration you can set DataRegion with persistence. Have you tried this? Evgenii -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Ignite Cluster: Cache Misses happening for existing keys

2018-09-13 Thread Вячеслав Коптилин
Hello, Your code contains the following obvious race: String value = *cache*.get(key); *if *(value == *null*) { *cache*.put(key, *getNewValue*()); *LOG*.info(*"Cache put key={} "*, key); } It's easy to imagine that two threads managed to execute get() method and got

Re: Multiple table data load problems are configured in a cache

2018-09-13 Thread Evgenii Zhuravlev
Hi, Basically, you will need to load data from 2 tables instead of one. Do you really need to have 2 tables in one cache? Looks like you just make your code more complicated. I'd recommend to haave separate caches for each table and different implementations of CacheStores. Evgenii чт, 13 сент.

Multiple table data load problems are configured in a cache

2018-09-13 Thread hulitao198758
Two tables are configured in a Customer cache, including the JDBC map of the third-party database. How to import the data using the LoadCache method? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/