Spark to Ignite Data load, Ignite node crashashing

Hello Ignite team, I a writing data from Spark Dataframe to Ignite, frequently one node goes down, I dont see any error in log file below is the trace. If i restart it doesn't join Cluster unless I stop the Spark job which is writing data to Ignite Cluster. I have 4 nodes with 4CPU/16GB RAM

Re: Distributed closure with buffer of binary data

Ok, but I think it's the same like WriteArray. For the moment I solved in a different way,using a encode/decode functions. Thanks, On Wed, Aug 8, 2018 at 11:06 AM Ilya Kasnacheev wrote: > Hello! > > How about WriteInt8Array >

Re: two data region with two nodes

tks, I will try the oldest node select method to ensure only one node to process the event message. As mentioned earlier, in my project ,I have several modules。eg： module A , daemon node with cache nodecache,machinecache .all the cache persistent。 module B, search node with cache

Re: Ignite with POJO persistency in SQLServer

Hi All, I tried mapping the fields in number of different combinations based on the above, but all the time I am failing with the SQLServerException: The conversion from UNKNOWN to UNKNOWN is unsupported. The mappings I used in the following structure included:

Re: SYSTEM_WORKER_TERMINATION (Item Not found)

Hi, I'm not sure that nightly builds are updates regularly, but you should a try. The biggest impact that nightly build could have some bugs that will be fixed on release. Thanks! -Dmitry -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Ignite with POJO persistency in SQLServer

Thank you for the help! -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

continous query remote filter issue

hello. It looks like peerAssemblyLoadingMode flag doesn’t work correctly in case of CacheEntryEventFilter: As an example: 1) This code works fine and I see “Hello world” on the server console. It means that HelloAction class was successfully transferred to server. class Program {

Re: Ignite with POJO persistency in SQLServer

Yes. In case if you don't want to store it as objects then you can move this fields to original object: class a{ Int a; class b; } class b{ int b; int c; } You can change it as next: class a{ int a, int b; int c; } -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Partitions distribution across nodes

Hi, I introduced the delay of 5 seconds and it worked. 1) What is exchange process and how to identify whether exchange process is finished? 2) I am doing partition key aware data loading and I want to start load process from server node only and not from the client node. I just want to

Re: what are the tehcniques to automatically detect changes in Multiple DBs and automatically push them into Ignite Cache

Thanks Juan .. I will check on the same From: "Juan Rodríguez Hortalá" To: user@ignite.apache.org Date: 07-08-2018 08:44 Subject:Re: what are the tehcniques to automatically detect changes in Multiple DBs and automatically push them into Ignite Cache That looks like

Re: Getting an exception when listing partitions of IgniteDataFrame

Hi Ray, I could not find a solution to the problem. I moved away from Ignite for now, so did not dig into it further. Regards, Rama. On Wed, Aug 8, 2018 at 2:55 PM Ray wrote: > Hi Rama, > > Did you solve this problem? > Please let me know your solution if you have solved this problem. > >

Re: Ignite with POJO persistency in SQLServer

Andrei, As I understand you - the only way to map embedded classes is by using mapping them as objects and store as BLOBs or other VARBINARY fields in SQL database? No way to decompose them into separate fields in the tables? Eg. ListingCode has: private String code; private String

Re: Getting an exception when listing partitions of IgniteDataFrame

Hi Rama, Did you solve this problem? Please let me know your solution if you have solved this problem. Thanks -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Optimum persistent SQL storage and querying strategy

Hello Jose, Did you consider Mongo DB for your use case? 2018-08-08 10:13 GMT+03:00 joseheitor : > Hi Ignite Team, > > Any tips and recommendations...? > > Jose > > > > -- > Sent from: http://apache-ignite-users.70518.x6.nabble.com/ >

Re: MySQL cache load causes java.sql.SQLException: GC overhead limit exceeded

Hello! We will be glad to hear if you will gather more details about the issue. Regards, -- Ilya Kasnacheev 2018-08-07 22:35 GMT+03:00 Orel Weinstock (ExposeBox) : > I've used the web-console generated LoadCaches file. From what I > understand, looking at the source code, this is not

Re: Distributed closure with buffer of binary data

Hello! How about WriteInt8Array ()? Regards, -- Ilya Kasnacheev 2018-08-08 11:19 GMT+03:00 F.D. : > Hello Igniters, > > My distributed closures work perfectly when

Distributed closure with buffer of binary data

Hello Igniters, My distributed closures work perfectly when the inputs are strings, but when I try to pass a buffer of bytes I got an error. The buffer of bytes arrives to me in a std::string but when I to use BinaryWriter::WriteString the string is truncated (ok, it was predictable). The

Re: Partitions distribution across nodes

Hi Akash, How do you measure partition distribution? Can you provide code for that test? I can assume that you get partitions before exchange process if finished. Try to use delay in 5 sec after all nodes are started and check again. Thanks! -Dmitry -- Sent from:

Re: Optimum persistent SQL storage and querying strategy

Hi Ignite Team, Any tips and recommendations...? Jose -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Question

Hi, It defines by AffinityFunction [1]. By default 1024 partitions, affinity automatically calculates nodes that will keep required partitions and minifies rebalancing when topology changes (nodes arrive or quit).