HI Andrey,
Thanks for raising bug.
We are using 1.7.0 branch. Could you please point me the branch of 1.7.0
I checked out from https://github.com/apache/ignite/tree/1.7.0, it is
1.7.0-SANPSHOT and have add code to verify the fix.
I see following warnings in log. should I checkout any other bran
Hi,
Could you please paste the OSGi imports of the bundle that contains the
Activator?
Could you also post a full stacktrace?
Thanks.
On 3 Nov 2016 19:31, "Denis Magda" wrote:
> *Raul*, could you assist with this issue?
>
> —
> Denis
>
> On Nov 3, 2016, at 8:39 AM, devis76 wrote:
>
> Hi,
> i
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.
Is there a way to disable all of these event notifications going to clients?
I've started noticing a lot of issues with OOM and crashing. After some
debugging, I've discovered the issue:
Server loading millions of rows of binary objects by calling cache.load()
utilizing cachestoreadapter. Clien
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 IgniteConfiguration igniteConfiguration() {
> c
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]
http://apache-ignite-users.70518.x6.nabble.com/KARAF-4-6-4-8-Snapshot-IgniteAbstractOsgiContextActivator-tp8552p8650.htm
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 the JdbcResultSet. v
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 Mashenko
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 all the time for stri
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 Thu, Nov 3, 2016 at 5:39 PM,
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 gener
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 RoundRobinLoadBalancingS
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:
http://apache-ignite-users.70518.x6.nabble.com/Killing-a-node-under-load-stall
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 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 {
ensureNotClosed();
ensureHasCurrentRow();
try {
T val = cls == String.class ? (T)String.valueOf(curr.get(colIdx
- 1)) :
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
> {
> ensureNotClosed();
> ensureH
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,
>
> Please attach whole examp
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]: o.a.i.confi
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 Ant
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 will try the debug opt
Hi,
thank you for your support.
Yes i think that Karaf has some issue... because your features.xml for me
it's ok... i have no idea "how to fix"... but for now i can continue to test
Ignite with Karaf...
Da: Sergej Sidorov [via Apache Ignite Users]
[mailto:ml-node+s70518n8650...@n6.nabble.
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()){
getStreamer().addData(entry.getKey(), en
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 Cache...
cacheCfg.setBa
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] -
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 b
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 datast
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 n
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
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 exception.
>
> java.lang.Il
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
org.apache.ig
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 h2-1.
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 ig
32 matches
Mail list logo
