In fact, I do not use the XML file to set the cache configuration. It seems
that I had to connect to the Internet each time I launch the application,
there is no local XML file cache(I remember the spring seems to fetch local
XML file if there is one, the usage of spring in ignite is differ from th
Hi,
We have a simple client server mode of apache ignite and we see a memory
increase in server node heap while doing "cache.get(cacheKey)".
Below is our scenario.
1. First we insert a one object list with "cacheKey".
2. Then we get it for like 200 times. In that case ser
Hi vijayendra,
I think you run one client node () wihout at last one server node. In that case client node
be waiting for server node until it (server node) will not by added.
When you start another node in server mode (), client will continue to work.
If it not help you, please provide addition
It looks like the XML file you are using is not valid. Can you share the
config with us?
Thank you, I will try with the nightly build.
Is there a benchmark / study that calls out the concurrency aspect of the
data grid?
Thanks,
Arthi
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/Concurrent-SQL-Requests-lead-to-errors-tp3844p3921.html
Sent from th
Thanks Igor
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/Host-Arrays-in-C-API-tp3707p3920.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.
Hi,
I am trying to query over a 1 node Apache Ignite Data grid.But my client
program is not getting exiting, it keeps on running.
Please let me know what needs to be done.I am running the client program in
client mode.
Regards,Vij
Hi Alex,
Do you set "other server addresses" in IP form? If you don't please try
to set an IP address instead of a host name.
In general the delay may be caused by your machine networking layer that
converts host names to IP addresses quite long.
--
Denis
On 4/5/2016 4:17 AM, Alex Lee wrot
Hi Pavel,
I was playing around with different options and once I specified
[Serializable] annotation at the entity class level, I was able to
successfully insert into cache. With this setting LoadCache() method is
working as well. Not sure if this is the right approach. I will not prefer
this as
I copied the config file to all other nodes then it throws:
-
Exception in thread "main" org.apache.spark.SparkException: Job aborted due
to stage failure: Task 1 in stage 0.0 failed 4 times, most recent fai
Hi, Denis
Thanks for your answer.
I had removed other configurations except Local IP Address.
after that, the time delay was not exist anymore.
but, if I add other server addresses, the delay occurs.
So, are there any configuration setting to reduce these delay ?
thank you.
--
View this mes
Hi Pavel,
I am not able to send the solution zip in gmail. It is blocking as the
zip file contains executables. Can you please check if you can download the
solution from the below location:
https://drive.google.com/open?id=0B8lM91-_3MwRS3pFU2JwRjJkYVU
Thanks,
Murthy.
On Mon, Apr 4, 2016 at 1
Yes, it works with OptimizedMarshaller. Thank you.
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/How-to-configure-user-data-type-for-sql-queries-tp3867p3912.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.
Hi Shaun,
If the data is small, you can simply switch to replicated cache. Will this
work for you?
-Val
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/Cache-write-through-for-backup-entries-tp3861p3911.html
Sent from the Apache Ignite Users mailing list archiv
>From the error message "Spring XML configuration path is invalid:
/home/test/SparkIgniteStreaming/config/example-cache.xm" my guess is that
the configuration file is absent on the Spark executor node.
2016-04-04 8:17 GMT-07:00 Yakov Zhdanov :
> Thanks for sharing the code. Alex Goncharuk, can yo
Hello,
I would suggest you to follow the following algorithm when calculating
memory usage by Ignite.
CALCULATING THE MEMORY USAGE
1. Calculate primary data size: multiply the size of one entry in bytes by
the total number of entries. Note, that Ignite will typically add around 200
bytes overhead
Hi Arthi,
Host arrays is not something that we have planned for the nearest
release. However, I have reproduced and investigated the issue
that you have provided and it is very likely that we are going to
optimize cursor operations in the nearest future which should
fasten your code a lot. You can
Oh ok...will try that option. Sure, will send you the zipped copy of my
solution for you to investigate further. Thanks much for your help.
Satya,
On Mon, Apr 4, 2016 at 11:09 AM, Pavel Tupitsyn
wrote:
> LoadCache arguments are serialized and passed over network. Cache instance
> can't be used
Thanks for sharing the code. Alex Goncharuk, can you please take a look?
--Yakov
I think javadocs are not 100% correct. I am pretty sure exception will be
thrown if connection to some node cannot be established, but if node A
already have active connections to all nodes you want to send message to
then message will be put to per-connection queues and will be sent in async
manne
LoadCache arguments are serialized and passed over network. Cache instance
can't be used as a LoadCache argument.
Please try to do a cache put directly in the main method:
using (var ignite = Ignition.Start(cfg))
{
var cache = ignite.GetCache(
null);
Hi Pavel,
I was trying to do that before and ran into issues passing cache object
to my CacheAdapter implementation which is in a different dll. Can you
please help where I went wrong:
In my main program, I was passing cache in LoadCache method:
using (var ignite = Ignition.Start(cfg))
Hi Igor,
Is this something we can expect as a feature in the near future? Please let
us know if this is tracked as an enhancement / jira issue.
Thanks for your help,
Arthi
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/Host-Arrays-in-C-API-tp3707p3902.html
Sen
Sorry, this was a mistake. I was running the query on a partitioned cache
instance. When I changed it to a replicated cache object, the results were
looking good.
Thanks,
Arthi
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/Queries-using-two-replicated-caches-g
Hi Val,
thanks for the reply.
My use-case is as follows: I have a small cache (say 10 entries) across
3 processes. I don't have a shared backend store. If I have one primary and
one backup then I can recover from a failure of 1 processes. But I can't
recover from a failure of 2 processes. If
Hello,
As a next step in my tests I am trying to run a sql query via the JDBC
driver against my loaded 'activity' cache.
A first test works fine:
rs = conn.createStatement().executeQuery("select * from activity");
Adding a condition to that results in a weird error, for example:
rs = conn.create
Instead of LoadCache, can you try a simple cache put and see what happens?
cache[1] = new CustomTransactionsDetail();
and with entity from EF:
cache[2] = entities.CustomTransactionsDetails.First();
Pavel.
On Mon, Apr 4, 2016 at 3:20 PM, Murthy Kakarlamudi wrote:
> Sorryattached the wrong
Sorryattached the wrong version. Below is the full entity class and the
CacheStore implementation.
namespace MyIgnite
{
using System;
using System.Collections.Generic;
public partial class CustomTransactionsDetail
{
public Nullable TransactionID { get; set; }
p
Satya,
In your code above there is "act(entry.personDetailID, entry);",
but there is no personDetailID member in the CustomTransactionsDetail
class.
Are you sure this is the correct one? Also, it is a partial class - are
there any parts in other files?
Can you attach full source code of your appl
Hi Denis,
Thanks for the answer.
Better if i provide more detail to get a point . Lets say i have cache1 and
cache2.
- I would like to run a query on cache1. Than i should check if key exists
or not in cache2 than i will execute some logic.
I need to make sure that keys are owned by queried nod
I use two IgniteContext instance in my spark streaming job, one
IgniteContext contains a cacheConfiguration, the cacheConfiguration was for
the dataframe to join.
Here the code is:
-
package main.
Below is my entity. I am not doing any serialization currently while
storing in the cache.
namespace MyIgnite
{
using System;
using System.Collections.Generic;
public partial class CustomTransactionsDetail
{
public Nullable TransactionID { get; set; }
public string
You can also download a nightly build:
https://builds.apache.org/view/H-L/view/Ignite/job/Ignite-nightly/lastSuccessfulBuild/
On Mon, Apr 4, 2016 at 2:19 PM, Denis Magda wrote:
> Hi Arthi,
>
> This the issue that has been fixed recently
> https://issues.apache.org/jira/browse/IGNITE-2542
>
> You
Satya,
Looks like exception comes from your entity member(s) during serialization.
Can you please attach your entity class code?
* Does it have any navigation properties that may cause SQL queries?
* How do you serialize it in Ignite? (Do you implement IBinarizable?)
Thanks,
Pavel.
On Mon, A
Hi Tolga,
Do you really need to iterate over *all the keys* when data has to be
update? If so then you can parallelize ScanQueries when multiple local
Threads will be iterating over specific partitions on each node.
Please refer to this example for more details
https://github.com/gridgain/gridgain
Hi Team,
I have a cluster with two replicated caches. A SQL query joining the two
caches is not returning correct results. If my cluster has two nodes, it
gives double the records... I did a distinct in the query and it returned
correctly.
Is this a known issue? Or am I doing something wrong.
Th
Hi Arthi,
This the issue that has been fixed recently
https://issues.apache.org/jira/browse/IGNITE-2542
You can wait for the next release or build Ignite from sources to overcome
the issue on your side.
--
Denis
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/
Hi Alex,
As I see from the sources 10 seconds delay can be introduced by a part of
the code that tries to resolve local host names to IP addresses. If the
resolution works slowly on the machine this can definitely lead to the
delay.
To check whether this assumption is correct or not specify a par
Hi Pavel,
Thanks for your response. I stepped through the LoadCache method in
debug mode and noticed that it is failing at the act() method. Below is my
code for LoacCache.
public override void LoadCache(Action act, params object[]
args)
{
var personDetailsList = entities.pe
Thank you, that already helps me a lot!
One further question though. Given your answer and the javadoc documentation, I
assume that the unordered send method in IgniteMessaging is blocking until
all recipients in the topic have received the message, right? And if any of the
recipients fails to r
Philipp,
Messaging works on top of Ignite internal communication sub-system. Message
delivery is guaranteed, unless recipient node has not left the grid. If it
leaves (i.e. topology gets EVT_NODE_LEFT or EVT_NODE_FAILED), then sender
clears internal queue associated with left node. When node rece
Hi!
Can you please provide the code you are trying to execute and full logs of
execution. Seems that IgniteContext was not properly initialized.
--
Yakov
Hi all
I am considering using Ignite messages to manage some jobs in my cluster. I've
seen that one can send messages either in an ordered or unordered fashion,
but the documentation does not specify any further guarantees. So far I have
come up with the following questions:
- Is delivery of po
Thanks,
hooked up the jar's and it looks like its loading the data into the cache
now!
best regards
jan
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/Ignite-Schema-Import-Utility-BinaryMetadata-mismatch-error-when-using-gerenated-classes-tp3857p3881.html
S
Jan,
I think you need to download jar from Jenkins from link provided by Dmitriy.
On Mon, Apr 4, 2016 at 3:21 PM, jan.swaelens wrote:
> Thanks,
>
> Is the '1.6.0-SNAPSHOT' available on a maven repo somewhere or do I just
> download the ZIP and use the extaracted jars?
>
> br
> jan
>
>
>
> --
>
Hi everyone,
Basicly i have a simple cache with almost 5m~ entries across 4 nodes. And i
use fair affinity function as affinity function.
I also use fair affinity function to send data to nodes from external
sources. My flow can be summarised as.
- Run 4 node cluster with a partitioned cache
-
Hi Satya,
"*Timeout expired. The timeout period elapsed prior to completion of the
operation or the server is not responding.*"
This is an SQL exception. Please make sure that your entity connection
works.
You can set a breakpoint on the first line of LoadCache method, step over
your code and see
Thanks,
Is the '1.6.0-SNAPSHOT' available on a maven repo somewhere or do I just
download the ZIP and use the extaracted jars?
br
jan
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/Ignite-Schema-Import-Utility-BinaryMetadata-mismatch-error-when-using-gerenated
48 matches
Mail list logo
