Hi guys,
I was using ignite in cluster mode with SQL. Recently, I start create and
drop table per 5 minutes. After few hours, an error will occur and the
whole cluster seems done. Error logs shows below. Any idea what should I do
to avoid this error again? Thanks a lot.
Hi,
Sorry for the earlier confusion, the type of apn_id/apnId is indeed String. I
had written a simple producer to publish messages to kafka topics with random
values the types of which are
id java.lang.String
reportStartTime java.lang.Long
reportEndTime java.lang.Long
apnId
I have a 1 node cluster.
Ignite persistence turned on.
I create a bunch of tables with SQL.
At some point, I drop the table with SQL and try to create it again but it
says table already exists.
I try to execute Drop table once more, it says the table doesn't exist.
After I restart the cluster(I
Hello,
Our end production cluster would be working with many billions of entities
in many caches, and have use cases where we need to run ScanQuery over an
entire cache to update certain fields.
We expect that there could definitely be failures in the middle of a single
ScanQuery due to the
classification and clustering
Importantly, critical for us to ensure, we have all the hooks to write our
algorithms from datasets.
Will provide more feedback in the next 1-2 months.
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
Ok, will wait your feedback, also we are going to add example to master "how
to work with SQL cache from ML module"
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
To simplify our use-case, we created two caches using the SQL query and
loaded data consisting of about 4 million records and 60k records
approximately, in the respective caches with INDEX created on all the
columns. Ignite is set up to run on a single node, meaning all the data is
present on the
Thread [name="sys-stripe-1-#2", id=17, state=WAITING, blockCnt=8, waitCnt=8]
Lock [object=java.util.concurrent.Semaphore$NonfairSync@6915e1ad,
ownerName=null, ownerId=-1]
at sun.misc.Unsafe.park(Native Method)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
And can you also clarify which thread pool is used for cache.put() /
cache.putAsync ?
I'm getting a lock whit two nodes when putting data into the cache with
map.forEach((key, value) -> cache.putAsync(key, value));
I could also try putAllAsync() but don't know if that is better than
putAsync.
Can anyone help?
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
Hello!
In your XML apn_id looks like String. Is it possible that actual type of
apnId in ApnDiameter5Min is neither Long nor String but some other complex
type? Can you attach those types?
Regards,
--
Ilya Kasnacheev
ср, 23 янв. 2019 г. в 18:37, Premachandran, Mahesh (Nokia - IN/Bangalore) <
Hi,
conf are as follows:
http://www.springframework.org/schema/beans;
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd;>
Kotlin code are
Which is better among Serializable and Externalizable?
I have experienced Externalizable is slower than Serializable. Can somebody
help me with this?
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
Hi,
As Mike mentioned, there is a good documentation about deployment in
Kubernetes [1]. The preferable way to configure discovery is
TcpDiscoveryKubernetesIpFinder [2]. Don't forget about serviceName and
namespace parameters.
Once you deployed a cluster you will be able to connect a node using
14 matches
Mail list logo
