Re: Disabling client notifications

I meant to say the cache is loaded by ignite.cache(cacheName).loadCache(null); -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Disabling-client-notifications-tp8704p8705.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Question about Class Not found

Raul, could you assist with this issue? — Denis > On Nov 3, 2016, at 8:39 AM, devis76 wrote: > > Hi, > i have found my problem, but i have no idea how to resolve. > > Activator extends IgniteAbstractOsgiContextActivator > @Override > public

Fwd: KARAF 4.6/4.8.Snapshot IgniteAbstractOsgiContextActivator

Cross-posting to the dev list. Raul, could you have a look at the issue discussed under this [1] thread? Is this something that is fexable on the side of our OSGi module? [1]

Re: Null column values - bug

Yes, you are right. This is a bug. It seems there should be smth like this: wasNull == curr.get(colIdx - 1) == null; I've create an issue https://issues.apache.org/jira/browse/IGNITE-4175 Thanks Anil ! On Thu, Nov 3, 2016 at 9:45 PM, Anil wrote: > following code i see in

Re: Null column values - bug

following code i see in the JdbcResultSet. val is not null for null values for string types. then val == null is false. correct ? T val = cls == String.class ? (T)String.valueOf(curr.get(colIdx - 1)) : (T)curr.get(colIdx - 1); wasNull = val == null; On 3 November 2016 at 23:48, Andrey

Re: Null column values - bug

No, wasNull is true if column value is null otherwise false. You can have wasNull() is true but getInt() is zero. E.g. getInt() return type is primitive and default value (zero) shoud be return for NULL fields. On Thu, Nov 3, 2016 at 9:11 PM, Anil wrote: > wasNull is false

Re: Null column values - bug

wasNull is false all the time for string types. correct ? On 3 November 2016 at 20:39, Andrey Mashenkov wrote: > Javadoc says that null value should be returned. > > But from the other side, there is wasNull() method, that should be use for > null checks. > > > > On

Concurrent job execution and FifoQueueCollisionSpi.parallelJobsNumber=1

Can different nodes have different collisionSpi settings? What setting would take effect - the collisionSpi used to start the grid or the setting on the node executing the job or the setting on the node that submitted the task? I recently encountered a log file that could only have been

Re: Question about Class Not found

Hi, i have found my problem, but i have no idea how to resolve. Activator extends IgniteAbstractOsgiContextActivator @Override public IgniteConfiguration igniteConfiguration() { cfg.setPeerClassLoadingEnabled(false); RoundRobinLoadBalancingSpi spiRRLB = new

Re: Killing a node under load stalls the grid with ignite 1.7

the problem is when I am in write behind for order, how do I access the trade object. its only present in the cache. at that time I need access trade cache and that is causing issues. -- View this message in context:

Re: Null column values - bug

Javadoc says that null value should be returned. But from the other side, there is wasNull() method, that should be use for null checks. On Thu, Nov 3, 2016 at 5:39 PM, Andrey Gura wrote: > String.valuOf(null) return "null" string by contract. > > On Thu, Nov 3, 2016 at

Null column values - bug

HI , null values are returned as "null" with ignite jdbc result set. private T getTypedValue(int colIdx, Class cls) throws SQLException { ensureNotClosed(); ensureHasCurrentRow(); try { T val = cls == String.class ? (T)String.valueOf(curr.get(colIdx - 1)) :

Re: Null column values - bug

String.valuOf(null) return "null" string by contract. On Thu, Nov 3, 2016 at 5:33 PM, Anil wrote: > HI , > > null values are returned as "null" with ignite jdbc result set. > > private T getTypedValue(int colIdx, Class cls) throws SQLException > { >

Re: DataStreamer is closed

Regarding data streamer - i will reproduce and share the complete code. Regarding cache size() - i understood it completely now. i set auto flush interval and it looks good now. Thanks to both of you. On 3 November 2016 at 17:41, Vladislav Pyatkov wrote: > Hi Anil, > >

Re: Question about Class Not found

Hi, I can only guess which class in was not found, but I think you have not loaded jar on each nodes. You have several tricks: 1) Copy jar into classpath on each nodes 2) Turn on peertopeer class loader[1]. 3) Use query entry [2], without field annotation and method setIndexTypes [1]:

Re: DataStreamer is closed

Hi Anil, Please attach whole example. I can not found where is DataStreamer was closed in your case (Where is method o.a.i.IgniteDataStreamer#close() was invoked?). About cache size, It does not means anything, because Streamer caches entries and sends as batch. And yes, check each future, as

Re: DataStreamer is closed

Anil, getStreamer().addData() will return you IgniteFuture. You can check it result by fut.get(). get() will give you null in case data streamed and stored or throw an exception. On Thu, Nov 3, 2016 at 2:32 PM, Anil wrote: > > Yes,. that is only exception i see in logs. i

Re: DataStreamer is closed

Yes,. that is only exception i see in logs. i will try the debug option. thanks. though data streamer is not returning exception all the time, IgniteCache#size() remains empty all the time. It weird. 1. for (Map.Entry entry : m.entrySet()){

Question about Class Not found

Hi, i have a simple Pojo public class Client implements Serializable private static final long serialVersionUID = 2747772722162744232L; @QuerySqlField private final Date registrationDate; @QuerySqlField(index = true) private final String lwersion; ... I have create simple

Re: [EXTERNAL] Re: Exception while trying to access cache via JDBC API

I am starting my server node within my boot app[1]. Both my client and server nodes start from same code but I will get the service part with starts client out of it later. How can I not start ignite server and still manage to use same config in my external server node? (bold part below). [1] -

Re: [EXTERNAL] Re: Exception while trying to access cache via JDBC API

I went to local gradle repo and manually deleted other h2 versions. It’s working now. Thanks for looking into it. I have one more query – is there a way I can make ‘ignite-http-rest’ work with spring-boot? Last time when I checked with one of Ignite dev they mentioned that I can’t use it with

Re: DataStreamer is closed

Anil, Is it first and only exception at logs? Is it possible to debud this? You can set breakpoint at first line of org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl#closeEx(boolean, org.apache.ignite.IgniteCheckedException) This will give you information who stopping the

Re: [EXTERNAL] Re: Exception while trying to access cache via JDBC API

Hi! That part of the code [1] starts Ignite client's node. In order to client's node is working, sever node is required (instance of Ignite with clientMode(false)). Do you run both those node in the same process or you run separate spring boot instance? Please note that in order to start server

Re: DataStreamer is closed

Hi Anton, No. ignite nodes looks good. I have attached my KafkaCacheDataStreamer class and following is the code to listen to the kafka topic. IgniteCache is created using java configuration. I see cache size is zero after adding the entries to cache as well from KafkaCacheDataStreamer. Not sure

Re: DataStreamer is closed

Anil, Could you provide getStreamer() code and full logs? Possible, ignite node was disconnected and this cause DataStreamer closure. On Thu, Nov 3, 2016 at 1:17 PM, Anil wrote: > HI, > > I have created custom kafka data streamer for my use case and i see > following

DataStreamer is closed

HI, I have created custom kafka data streamer for my use case and i see following exception. java.lang.IllegalStateException: Data streamer has been closed. at org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.enterBusy(DataStreamerImpl.java:360) at

Re: [EXTERNAL] Re: Exception while trying to access cache via JDBC API

Ok, then please check your effective classpath: System.out.println(System.getProperty("java.class.path")); Also you can check where H2 classes come from: System.out.println(org.h2.Driver.class.getProtectionDomain().getCodeSource().getLocation()); In the end you must have in classpath only

Re: Which ports does ignite cluster need to run normally?

Hi, Does Apache Ignite need the entire range of ports to be opened. I mean, TcpDiscoverySpi：47500~47600 TcpCommunicationSpi：47100~47200 Is it mandatory to open the entire range of discovery ports in the range 47500~47600 and entire range of communication ports (47100~47200) in every member of

Re: [EXTERNAL] Re: Exception while trying to access cache via JDBC API

There are no remote nodes deployed yet. I am still in dev phase so trying to start ignite locally with just one instance from the code itself. -- Regards, Chetan. From: "Sergi Vladykin [via Apache Ignite Users]" Date: Thursday, November 3, 2016 at 12:50