Re: How can I obtain a list of executing jobs on an ignite node

Hi, I tried that and it "sort of works" in that I can get a map of task futures. However, what we really want is an ability to drill down and cancel a a particular job associated with the task. This post says that it is not possible -

Re: rest-http can't get data if key is Integer or others

sorry，i did't clear to this. the rest did't handle the key when not string， i show the code just for tell you where is the problem. my code did't handle about zero deployment，if the key object with distributed class loader, it maybe not work. so i think my code can't be use. can do this about

Connection Info

Hi, I am seeing few logs in ignite cluster as below. Should we really worry about these ? 2016-11-11 11:48:14 WARN grid-nio-worker-2-#42%my-grid% TcpCommunicationSpi:480 - >> Selector info [idx=2, keysCnt=1] Connection info [rmtAddr=/X.X.X.X:47100, locAddr=/X.X.X.X:54216, msgsSent=6519,

Re: Creating cache on client node in xml not working

Hi, No the server does not. I was hoping the bean would be added to the server automatically somehow. I guess not? If I had multiple nodes as servers would they all need access to the bean xml. So the same xml file on each node? Thanks From: Andrey Gura

Re: Creating cache on client node in xml not working

Hi, Does your Ignite server have cassandraAdminDataSource and other Cassandra related beans in classpath? On Fri, Nov 11, 2016 at 7:53 PM, Evans, Charlie wrote: > Hi all, > > > I've been trying to create a cache in my application with Cassandra as the > persistent

Creating cache on client node in xml not working

Hi all, I've been trying to create a cache in my application with Cassandra as the persistent storage. My current setup is: - starting Ignite on the server with default configs. - application connects to the ignite server as a client and attempts to load the cache configuration and create

Re: How is maxMemorySize calculated in the presence of backups?

Josh, Eviction policies track entries on local node only regardless of fact that this node is primary or backup for particular entry. So the policy will evict entries on particular node when this node will have 1G of heap. On Fri, Nov 11, 2016 at 6:49 PM, Josh Cummings

How is maxMemorySize calculated in the presence of backups?

For example, if I have an LruEvictionPolicy on a cache with one backup, and I say the maxMemorySize is 1G, will it evict when the primary has 1G or when the primary and the backup together have 1G? -- *JOSH CUMMINGS* Principal Engineer [image: Workfront] *O*

Re: Connection Cleanup when IgniteCallable Killed

Hi Jaime. Actually tasks are interrupted, you can find how it works in following code: (for Ignite 1.7) in GridJobProcessor.onEvent() calls GridJobProcessor.cancelJob(GridJobWorker, boolean) for each task that leads to interruption. If there down on your code was caught InterruptedException but

Re: Ignite Jdbc connection

HI Andrey, Thanks for your response. #2 answered from other answers You are right. i created only one connection and it looks good. thanks. On 11 November 2016 at 16:59, Andrey Gura wrote: > Hi, > > > 1. Ignite client node is thread-safe and you can create multiple >

Re: errors when building from source,?

I updated http://apacheignite.gridgain.org/v1.7/docs/getting-started# section-building-from-source. Also I downloaded http://apache-mirror.rbc.ru/pub/apache//ignite/1.7.0/apache-ignite-1.7.0-src.zip Unpacked and executed "mvn clean package -DskipClientDocs -Dmaven.javadoc.skip=true -DskipTests"

Re: errors when building from source,?

Hi, As far as I see you are following instruction from site. >> I followed this tutorial: http://apacheignite.gridgain.org/v1.7/docs/getting-started#section-building-from-source to But I think they are outdated. Version ignite-1.3.0 is very old. Please try with latest ignite-1.7.0 (

Re: Hive job submsiion failed with exception ”java.io.UTFDataFormatException“

Hi lapalette, Would you like to explain the way you have change Marshaller? It seems OptimizedMarshaler does not have these limitations, and its possible it was not configured in correct way. On Fri, Nov 11, 2016 at 4:30 PM, Andrey Mashenkov wrote: > Hi lapalette, > >

Re: errors when building from source,?

Hi! It seems that dependency is broken. Try remove it from maven repository and rebuild. For more information please refer http://stackoverflow.com/questions/13846357/can-maven-3-redownload-broken-files-instead-of-failing-the-build -- View this message in context:

Re: Hive job submsiion failed with exception ”java.io.UTFDataFormatException“

Hi lapalette, 1. Does this error appears in ignite 1.7 and it's not present in version 1.6? 2. Did you get same error with another marshallers? Would you please provide stacktraces with other marshallers? 3. What version of JVM do you use? Have you try to upgrade JVM? So, its JDK internals

Re: Very high memory consumption in apache ignite

Hi rishi007bansod. Are you sure all these memory consumped with java process? You can try to analyze pmap or vmmap tool report? https://plumbr.eu/ blog/memory-leaks/why-does-my-java-process-consume-more-memory-than-xmx Please, let me know if you find any suspicious thing. On Thu, Nov 10, 2016

start C++ server in linux?? it report "Failed to initialize JVM" error

Hi, all when I used jdk1.7.0 buiding ignite core?? and building C++ server in linux(Center OS) , when I start C++ server?? it report error as follow: ~/apache-ignite-1.7.0-src/modules/platforms/cpp/ignite]$ ./ignite ERROR: Failed to initialize JVM

Re: Visor console

Wow, easy! I will give it a try soon. Thanks, Paolo On Fri, Nov 11, 2016 at 10:19 AM, Alexey Kuznetsov wrote: > Hi Paolo! > > Yes, it is possible. > > See attached pom.xml and VisorStartup.java example. > > > On Fri, Nov 11, 2016 at 4:59 AM, Paolo Di Tommaso < >

Re: Ignite Jdbc connection

Hi, 1. Ignite client node is thread-safe and you can create multiple statements in order to query execution. So, from my point of view, you should close connection when finish all your queries. 2. Could you please clarify your question? 3. I don't think that pooling is required. 4. Ignite client

Re: Cache Memory Behavior \ GridDhtLocalPartition

Hi Isaeed Mohanna, I don't see any eviction or expired policy configured. Is entry deletion performed by you application? Have you try to detect which of caches id grows unexpectedly? Have you analyse GC logs or tried to tune GC? Actually, you can putting data faster as garbage is collecting.

Re: Ignite Cache setIndexedTypes Question

Hi, It is should not be very slow. If you will not use index, then SQL will work slow. You can try to use QueryEntity[1] without indexs on fields. How many index do you use? Could you please provide this classes? Please properly subscribe to the user list so that we can see your questions as

Re: Visor console

Hi Paolo! Yes, it is possible. See attached pom.xml and VisorStartup.java example. On Fri, Nov 11, 2016 at 4:59 AM, Paolo Di Tommaso wrote: > Hi, > > Is it possible to deploy the visor console in a embedded manner? I mean > just including the visor dependencies

Re: DataStreamer is closed

HI Anton, Sounds perfect ! #1 - i will reproduce and share you the logs. i have project commitment for coming Monday #2 - I will work on this from coming Tuesday. Thanks On 11 November 2016 at 14:25, Anton Vinogradov wrote: > Anil, > > >> I suspect there is a

Re: DataStreamer is closed

Anil, > I suspect there is a problem when node rejoins the cluster and streamer is > already closed and not recreated. Correct ? Correct, this seems to be linked somehow. I need logs and sourcess to tell more. I had to implement my own kafka streamer because of >

Re: DataStreamer is closed

HI Anton, Thanks for responding. i will check if i can reproduce with issue with reproducer. I had to implement my own kafka streamer because of https://issues.apache.org/jira/browse/IGNITE-4140 I suspect there is a problem when node rejoins the cluster and streamer is already closed and not

Re: java.lang.ClassNotFoundException: Failed to peer load class

Hi Alex. It looks like problem on client, because it was disconnected from server after try to retrieve class. Please, check if there are no other errors on client. Could you, please, repeat your test with -DIGNITE_QUIET=false and provide full client and server logs? Thanks! On Wed, Nov 9, 2016

Re: DataStreamer is closed

Anil, Unfortunately, at com.test.cs.cache.KafkaCacheDataStreamer.addMessage( KafkaCacheDataStreamer.java:149) does not fits on attached sources. But, java.lang.IllegalStateException: Cache has been closed or destroyed: PERSON_CACHE is a reason of closed datastreamer. It it possible to write