Hi,
I am using query as a consumer. My aim is to get the query result from an
existing cache when the data is inserted into Ignite's cache.
Can you point me any example for this.
Regards.
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/Camel-Ignite-cache-qu
Well when i look at active threads after i stop the node, i don't see any
active thread which was started by ignite. But i do see threads started by
Ignite in finished threads list on yourkit. I think that is fine.
When i try to start again, i get the IllegalThreadStateException exception.
Here
What threads are left behind? Do you have a thread dump that you can show?
-Val
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/Server-node-fails-to-start-with-exception-IllegalThreadStateException-tp14150p14171.html
Sent from the Apache Ignite Users mailing lis
Hi Sumanta,
The way how nodes discover each other depends only on discovery
configuration, it doesn't matter if nodes are started in embedded or
standalone mode. Please refer to [1] for all available options. On Google
Cloud you can use native integration [2].
[1] https://apacheignite.readme.io/d
Hello there, please my test project. You can see 1) The initialization seem
didn't finish 2) the streaming client stopped after a while.
If you take out the Atomic sequence part, the stream start to work.
Thank you for helping.
Jessie
--
View this message in context:
http://apache-ignite-users
Hi,
---The query used for QUERY operations (as a producer) or to launch the
continuous query (as a consumer)
Do you use query as a producer or as a consumer?
Evgenii
2017-06-29 17:20 GMT+03:00 austin solomon :
> Hi Evgenii,
>
> As you said I did not had registry bean in my context. I have crea
Hi Evgenii,
As you said I did not had registry bean in my context. I have created a
SimpleRegistry using the code below.
SimpleRegistry registry = new SimpleRegistry();
ScanQuery query = new ScanQuery<>(new
IgniteBiPredicate() {
private static final long serialVersionUID = 1L;
Hi Rish,
DataStreamer does not have any threads, DataStreamPool is used for incoming
batches processing.
DataStreamer split you data into batches which size is equal to streamer
perNodeBufferSize parameter.
When batch become full, a task is send to a node the buffer belongs to.
PerNodeParallelOpe
The node log is:
[17:36:21] ver. 2.0.0#20170430-sha1:d4eef3c6
[17:36:21] 2017 Copyright(C) Apache Software Foundation
[17:36:21]
[17:36:21] Ignite documentation: http://ignite.apache.org
[17:36:21]
[17:36:21] Quiet mode.
[17:36:21] ^-- Logging to file
'I:\Projects\Architecture\Ignite\apache-ignit
I have tried writing while loop which continuously inserts data(same entry)
with increamenting cache key(so that there is unique key). Without
datastrmr.addData() while loop is generating data at 200K msgs/sec(Data
generation rate is much more than caching rate). Is there any blocking done
by datas
Hi,
We are planning to deploy our application in google cloud. Our application
runs ignite server in embedded mode (i.e. ignite starts as part of spring
application start up). Was wondering - in this scenario, will ignite still
be able to figure out newly added members in the cluster automatically?
Hi Rishi,
Is it possible ignite put faster than you preparing data for put?
Or may be you change same entry each time and there is a contention on this
entry?
On Thu, Jun 29, 2017 at 7:44 AM, rishi007bansod
wrote:
> Hi,
> With datastreamer threads = 16(default) am able to get upto 80 K
>
Thank you for your interest people, it got resolved.
the issue was there was no stack memory available for the JVM to run for
that we need to pass an extra argument "-Xss2m" to JVM then it will work
but still it not clear for why that happened, the only changes that was
applied was increase in
It works for me without hangs, here is log:
Created Ignite cache: IgniteCacheProxy [delegate=GridDhtAtomicCache
[defRes=org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache$1@72f46e16,
near=null, super=GridDhtCacheAdapter
[multiTxHolder=java.lang.ThreadLocal@71104
duplicate for
http://apache-ignite-developers.2346864.n4.nabble.com/It-seems-WebSession-s-removeAttribute-does-not-support-HttpSessionBindingListener-td19184.html
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/It-seems-WebSession-s-removeAttribute-does-not-suppo
Hi,
It's not clear what do you want to do, but javadoc for QuerySqlFunction
contains some sample code for usage it:
https://ignite.apache.org/releases/mobile/org/apache/ignite/cache/query/annotations/QuerySqlFunction.html
How do you want to use HA with cluster singleton?
What do you mean by Igni
16 matches
Mail list logo