Alternatives for XML configuration file(s)?

[monstereo]

When I worked on Apache Ignite, configuration with XML files was crashing me.
I could write configuration as a class. However I could not convert all the
configuration.
Is there any way such as Spring’s solutions?



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

When will Apache Ignite support Java 11?

[monstereo]

Is there any plan to support Java 11 for Apache Ignite?

If the next version of the Apache Ignite (2.7) will support Java 11, when it
will be released?



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Do I need CacheStoreFactory class and hibernate configuration on Remote Node?

[monstereo]

Simply hibernate example:

One node contains HibernateCacheStore and other configuration
(hibernate.cfg.xml vs...)
I have created that node and read database and write to cache (It works as
it is) (cache name is "hibernateCache")

Now I have created another node which has default configuration. Then in the
main app just contains::

public static void printCache(IgniteCache igniteCache){
System.out.println("Print the all caches");
Iterator> cacheIterator =
igniteCache.iterator();
while (cacheIterator.hasNext()){
Cache.Entry cacheEntry = cacheIterator.next();
System.out.println("Key: " + cacheEntry.getKey() + ", value:" +
cacheEntry.getValue());
}
}

public static void main...(){
   Ignite node = Ignition.start(defaultxmlpath)
IgniteCache cache = node.getOrCreateCache("hibernateCache");
System.out.println(cache.size());
printCache(cache);
}

even if I work on local mode(and server nodes become 2 when I run the other
node), I can not see the cache size on the screen and does not print the
cache. It just waiting!!!


Note that: I have tried peer class loading false and true, but nothing
changed.



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: WARN TcpDiscoverySpi:135 - Timed out waiting for message to be read(most probably....)

[monstereo]

I think you are right, when I killed some jar process on the systems, then it
does not give errors



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: WARN TcpDiscoverySpi:135 - Timed out waiting for message to be read(most probably....)

[monstereo]

Most the time, it happens when starting the first ignite node

I can not share logs at this time.
 But simply it prints that warning forever.



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

WARN TcpDiscoverySpi:135 - Timed out waiting for message to be read(most probably....)

[monstereo]

2018-09-17 10:51:00 WARN  TcpDiscoverySpi:135 - Timed out waiting for message
to be read (most probably, the reason is long GC pauses on remote node)
[curTimeout=1, rmtAddr=/127.0.0.1:47504, rmtPort=47504]

this warning is printing out on the screen, and my ignite node can not
start.
How do i solve this ?

Here is the discovery spi from my configuration.








127.0.0.1:47500..47509









--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: SEVERE: Failed to resolve default logging config file: config/java.util.logging.properties

[monstereo]

I have solved it.
Thanks..



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: class org.apache.ignite.IgniteIllegalStateException: Ignite instance with provided name doesn't exist.

[monstereo]

Is there any way to get only cache datas from ignite node(without creating
new one)
I can get via ClientCache cache = 
igniteClient.getOrCreateCache("sampleCache");
However, I could not iterate over it. 
I mean,  I want to:

Iterator> iter =
igniteCache.iterator();
while(iter.hasNext()){
System.out.println(iter.next().getValue());
}



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

class org.apache.ignite.IgniteIllegalStateException: Ignite instance with provided name doesn't exist.

[monstereo]

Think of it, i will work on production.

Here is the igniteConfig.xml


// others default configuration.

I have started this node on terminal: here is the log

2018-09-06 10:39:22 INFO  IgniteKernal%as:95 - 

>>> +--+
>>> Ignite ver. 2.5.0#20180523-sha1:86e110c750a340dc9be2d3964113
>>> +--+
>>> OS name: Linux 4.4.0-134-generic amd64
>>> CPU(s): 4
>>> Heap: 1.3GB
>>> VM name: 15276@ubuntu
>>> Ignite instance name: sample


Now on the ide: I have written

public static void main(String[] args) {
Ignite node  = Ignition.ignite("sample");
slf4jLogger.info("\n\n" + node.toString() + "\n\n");
}

but it gives me error:
Exception in thread "main" class
org.apache.ignite.IgniteIllegalStateException: Ignite instance with provided
name doesn't exist. Did you call Ignition.start(..) to start an Ignite
instance? [name=sample]




--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Need IgniteConfiguration and XML at the same time? IgniteStormStreamer?

[monstereo]

I thought that I could connect specific ignite node via setting
userAttributes in the xml configuration.



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Need IgniteConfiguration and XML at the same time? IgniteStormStreamer?

[monstereo]

thank you for your response
you comments helped me alot

But there is point about IgniteStorm, one way or another I can run the code
via ide.(using ignite-storm). However when I convert to there was error like
you said backward compability. That's why I gave up to do with ignite-storm,
just do it simply cache.put(...)

may i ask how to get instance of specific ignite node: (assume that in
terminal mode ignite run on port 47501 and when i write Ignite ignite =
Ignition.ignite(), I just want to connect that node) (not creating new one)



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Need IgniteConfiguration and XML at the same time? IgniteStormStreamer?

[monstereo]

Here is the pom.xml ->   pom2.xml
  
Here is the node configuration ->   node.xml
  



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Need IgniteConfiguration and XML at the same time? IgniteStormStreamer?

[monstereo]

I have many questions

*1)* This issue really annoying me, here is the error:(occurs in storm
project)
*java.lang.IncompatibleClassChangeError: Implementing class at
java.lang.ClassLoader.defineClass1(Native Method) ~[?:1.8.0_181]at
java.lang.ClassLoader.defineClass(ClassLoader.java:763) ~[?:1.8.0_181]  at
java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)
~[?:1.8.0_181]  at
java.net.URLClassLoader.defineClass(URLClassLoader.java:467) ~[?:1.8.0_181] 
at java.net.URLClassLoader.access$100(URLClassLoader.java:73) ~[?:1.8.0_181] 
at java.net.URLClassLoader$1.run(URLClassLoader.java:368) ~[?:1.8.0_181]
at
java.net.URLClassLoader$1.run(URLClassLoader.java:362) ~[?:1.8.0_181]   at
java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_181] 
at java.net.URLClassLoader.findClass(URLClassLoader.java:361) ~[?:1.8.0_181] 
at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[?:1.8.0_181] 
at
sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349) ~[?:1.8.0_181] 
at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ~[?:1.8.0_181] 
at
java.lang.Class.forName0(Native Method) ~[?:1.8.0_181]  at
java.lang.Class.forName(Class.java:264) ~[?:1.8.0_181]  at
org.apache.ignite.internal.util.IgniteUtils.addLog4jNoOpLogger(IgniteUtils.java:8366)
~[ignite-core-2.5.0.jar:2.5.0]  at
org.apache.ignite.internal.IgnitionEx.start(IgnitionEx.java:930)
~[ignite-core-2.5.0.jar:2.5.0]  at
org.apache.ignite.internal.IgnitionEx.start(IgnitionEx.java:854)
~[ignite-core-2.5.0.jar:2.5.0]  at
org.apache.ignite.internal.IgnitionEx.start(IgnitionEx.java:724)
~[ignite-core-2.5.0.jar:2.5.0]  at
org.apache.ignite.internal.IgnitionEx.start(IgnitionEx.java:693)
~[ignite-core-2.5.0.jar:2.5.0]*

now, i have solved but i need proper solution, because i know that when i
convert to jar, it gives me error(always it gives).
Here is the my solution: according to the this line
"org.apache.ignite.internal.util.IgniteUtils.addLog4jNoOpLogger", 
I have realized that ignite-storm uses storm and log4j as a dependency
Then I excluded these dependency from pom.xml, and it works. 
However, this is really stupid issue, do i have to care all dependency all
the time?

*2)* Link that you provided says that  // if an ignite instance is already
started in same JVM then use it.
can you explain this. Right now i am working on local mode.
I already open one ignite node on the terminal.
then I open one ignite node inside the storm project
Now, I am opening 2 different JVM or one. (Same question for production
mode, think of it terminal and storm project are inside different machines)

*3)* As far as I know, StormStreamer igniteStormStreamer =
new StormSt.. () this, it creates new ignite node.
For my project, I have one ignite node on a machine,
Then to get cache data from that machine, I will open another ignite node in
storm (actually in spout inside the open method)
Then I process the datas via spouts bolts etc..  
Then I will write the last processed data to new ignite cache (uses
StormStreamer)
However, because of I have created ignite node once, when I use
stormstreamer, i am getting IgniteAlreadyStarted exceptions
How can i solved that? (Note that: I have to be sure that one ignite node
will be created in the storm)



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Need IgniteConfiguration and XML at the same time? IgniteStormStreamer?

[monstereo]

I want to integrate ignite with storm via ignite-storm dependency
Because of Storm works with Threads, I had to use:

*Ignite node =Ignition.getOrStart(...),*

and this method only takes IgniteConfiguration instance. Here is the method
declaration:
   
*public static Ignite getOrStart(IgniteConfiguration cfg) throws
IgniteException *

If I do not use this method, I will get Ignite already started exception.

Now, I want to set ignite bolt via:

 igniteStormStreamer = new StormStreamer<>();
...
*builder.setBolt("igniteBolt",
igniteStormStreamer).shuffleGrouping("OtherBolt");*

and this igniteStormStreamer needs
*igniteStormStreamer.setIgniteConfigFile(getProperties().getProperty("ignite.config"));*

however, when i put class path to this ignite.config property, gives me
error:

*Caused by: org.apache.ignite.IgniteException: Spring XML configuration path
is invalid: apacheIgnite.CreateIgniteConfiguration. Note that this path
should be either absolute or a relative local file system path, relative to
META-INF in classpath or valid URL to IGNITE_HOME.*

when i put xml file to this ignite.config property, gives me error:
*8137 [Thread-26-igniteBolt-executor[5 5]] ERROR o.a.s.d.executor - 
java.lang.IncompatibleClassChangeError: Implementing class*


how can i should this issue?










--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Eviction Policy on Dirty data

[monstereo]

yes, using cachestore and write through

dkarachentsev wrote
> Hi,
> 
> Could you please explain how do you update database? Do you use CacheStore
> with writeThrough or manually save?
> 
> Anyway, you can update data with custom eviction policy:
> cache.withExpiryPolicy(policy) [1]
> 
> [1]
> https://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/IgniteCache.html#withExpiryPolicy-javax.cache.expiry.ExpiryPolicy-
> 
> Thanks!
> -Dmitry
> 
> 
> 
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Eviction Policy on Dirty data

[monstereo]

Let's say, I have cache in ignite.
And one data is dirty(I mean, i have to upload correspond database for this
data)
Before updating, let's say I added one element to the cache and eviction
policy occured(and dirty data will be removed).

is there any mechanism to prevent eviction of dirty data before updating
correspond database?
or
this situation never becomes?



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Ignite instance with provided name doesn't exist. Did you call Ignition.start(..) to start an Ignite instance?

[monstereo]

I have started Ignite node with 
igniteConfiguration.setIgniteInstanceName("sample");

now,i want to get instance of this 'sample' node

here is the main app(assume that sample is node is running)
 
public static void main(String[] args) throws IgniteCheckedException {

System.out.println(Ignition.ignite("sample").toString());

}

But gives me the error 'Ignite instance with provided name doesn't exist.
Did you call Ignition.start(..) to start an Ignite instance?'

even if, i could see that  'Ignite node started OK (id=e27694f2, instance
name=sample)' 



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: SEVERE: Failed to resolve default logging config file: config/java.util.logging.properties

[monstereo]

Does not work again. 
Maven is really interesting thing 

Here i the pom.xml, after your suggestion  pom.xml
  


Same error was given

(Note that: there was no error when I convert to jar with one-jar plugin)



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: SEVERE: Failed to resolve default logging config file: config/java.util.logging.properties

[monstereo]

No it does not work.
I am using intellji, I run the tools > xml action > validate,
for pom.xml and config.xml, and intellji said 'No errors found'
but same error exists.

(note that: i have also tried to change the configuration xml with default
configuration(and add just propery=gridLogger, but same error was given)


ezhuravlev wrote
> Well, you just broke xml, so it can't even be parsed. I sure you can fix
> it
> by using any XML validator - all IDEs have this built-in.
> 
> 
> 
> 2018-08-13 10:06 GMT+03:00 monstereo 

> mehmetozanguven@

> :
> 
>> I have tried with your suggestion, but this time there is an error like
>> this:(when I remove Property 'includeEventTypes from xml configuration,
>> it
>> works FINE!!)
>> Here is the pom.xml
>> http://apache-ignite-users.70518.x6.nabble.com/file/t1901/pom.xml;
>>
>>
>> Caused by:
>> org.springframework.beans.factory.parsing.BeanDefinitionParsingException:
>> Configuration problem: Unexpected failure during bean definition parsing
>> Offending resource: URL [jar:file./config.xml]
>> Bean 'ignite.cfg'; nested exception is
>> org.springframework.beans.factory.parsing.BeanDefinitionParsingException:
>> Configuration problem: Unable to locate Spring NamespaceHandler for XML
>> schema namespace [http://www.springframework.org/schema/util]
>> Offending resource: URL [jar:file:./config.xml]
>> Bean 'ignite.cfg'
>> -> Property 'includeEventTypes'
>> at
>> org.springframework.beans.factory.parsing.FailFastProblemReporter.error(
>> FailFastProblemReporter.java:70)
>> at
>> org.springframework.beans.factory.parsing.ReaderContext.
>> error(ReaderContext.java:85)
>> at
>> org.springframework.beans.factory.xml.BeanDefinitionParserDelegate.error(
>> BeanDefinitionParserDelegate.java:308)
>> at
>> org.springframework.beans.factory.xml.BeanDefinitionParserDelegate.
>> parseBeanDefinitionElement(BeanDefinitionParserDelegate.java:562)
>> at
>> org.springframework.beans.factory.xml.BeanDefinitionParserDelegate.
>> parseBeanDefinitionElement(BeanDefinitionParserDelegate.java:460)
>> at
>> org.springframework.beans.factory.xml.BeanDefinitionParserDelegate.
>> parseBeanDefinitionElement(BeanDefinitionParserDelegate.java:429)
>> at
>> org.springframework.beans.factory.xml.DefaultBeanDefinitionDocumentR
>> eader.processBeanDefinition(DefaultBeanDefinitionDocumentReader.java:299)
>> at
>> org.springframework.beans.factory.xml.DefaultBeanDefinitionDocumentR
>> eader.parseDefaultElement(DefaultBeanDefinitionDocumentReader.java:190)
>> at
>> org.springframework.beans.factory.xml.DefaultBeanDefinitionDocumentR
>> eader.parseBeanDefinitions(DefaultBeanDefinitionDocumentReader.java:169)
>> at
>> org.springframework.beans.factory.xml.DefaultBeanDefinitionDocumentReader.
>> doRegisterBeanDefinitions(DefaultBeanDefinitionDocumentReader.java:142)
>> at
>> org.springframework.beans.factory.xml.DefaultBeanDefinitionDocumentR
>> eader.registerBeanDefinitions(DefaultBeanDefinitionDocumentReader.java:94)
>> at
>> org.springframework.beans.factory.xml.XmlBeanDefinitionReader.
>> registerBeanDefinitions(XmlBeanDefinitionReader.java:508)
>> at
>> org.springframework.beans.factory.xml.XmlBeanDefinitionReader.
>> doLoadBeanDefinitions(XmlBeanDefinitionReader.java:392)
>> at
>> org.springframework.beans.factory.xml.XmlBeanDefinitionReader.
>> loadBeanDefinitions(XmlBeanDefinitionReader.java:336)
>> at
>> org.springframework.beans.factory.xml.XmlBeanDefinitionReader.
>> loadBeanDefinitions(XmlBeanDefinitionReader.java:304)
>> at
>> org.apache.ignite.internal.util.spring.IgniteSpringHelperImpl.
>> applicationContext(IgniteSpringHelperImpl.java:379)
>> ... 10 more
>>
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: SEVERE: Failed to resolve default logging config file: config/java.util.logging.properties

[monstereo]

I have tried with your suggestion, but this time there is an error like
this:(when I remove Property 'includeEventTypes from xml configuration, it
works FINE!!)
Here is the pom.xml
  


Caused by:
org.springframework.beans.factory.parsing.BeanDefinitionParsingException:
Configuration problem: Unexpected failure during bean definition parsing
Offending resource: URL [jar:file./config.xml]
Bean 'ignite.cfg'; nested exception is
org.springframework.beans.factory.parsing.BeanDefinitionParsingException:
Configuration problem: Unable to locate Spring NamespaceHandler for XML
schema namespace [http://www.springframework.org/schema/util]
Offending resource: URL [jar:file:./config.xml]
Bean 'ignite.cfg'
-> Property 'includeEventTypes'
at
org.springframework.beans.factory.parsing.FailFastProblemReporter.error(FailFastProblemReporter.java:70)
at
org.springframework.beans.factory.parsing.ReaderContext.error(ReaderContext.java:85)
at
org.springframework.beans.factory.xml.BeanDefinitionParserDelegate.error(BeanDefinitionParserDelegate.java:308)
at
org.springframework.beans.factory.xml.BeanDefinitionParserDelegate.parseBeanDefinitionElement(BeanDefinitionParserDelegate.java:562)
at
org.springframework.beans.factory.xml.BeanDefinitionParserDelegate.parseBeanDefinitionElement(BeanDefinitionParserDelegate.java:460)
at
org.springframework.beans.factory.xml.BeanDefinitionParserDelegate.parseBeanDefinitionElement(BeanDefinitionParserDelegate.java:429)
at
org.springframework.beans.factory.xml.DefaultBeanDefinitionDocumentReader.processBeanDefinition(DefaultBeanDefinitionDocumentReader.java:299)
at
org.springframework.beans.factory.xml.DefaultBeanDefinitionDocumentReader.parseDefaultElement(DefaultBeanDefinitionDocumentReader.java:190)
at
org.springframework.beans.factory.xml.DefaultBeanDefinitionDocumentReader.parseBeanDefinitions(DefaultBeanDefinitionDocumentReader.java:169)
at
org.springframework.beans.factory.xml.DefaultBeanDefinitionDocumentReader.doRegisterBeanDefinitions(DefaultBeanDefinitionDocumentReader.java:142)
at
org.springframework.beans.factory.xml.DefaultBeanDefinitionDocumentReader.registerBeanDefinitions(DefaultBeanDefinitionDocumentReader.java:94)
at
org.springframework.beans.factory.xml.XmlBeanDefinitionReader.registerBeanDefinitions(XmlBeanDefinitionReader.java:508)
at
org.springframework.beans.factory.xml.XmlBeanDefinitionReader.doLoadBeanDefinitions(XmlBeanDefinitionReader.java:392)
at
org.springframework.beans.factory.xml.XmlBeanDefinitionReader.loadBeanDefinitions(XmlBeanDefinitionReader.java:336)
at
org.springframework.beans.factory.xml.XmlBeanDefinitionReader.loadBeanDefinitions(XmlBeanDefinitionReader.java:304)
at
org.apache.ignite.internal.util.spring.IgniteSpringHelperImpl.applicationContext(IgniteSpringHelperImpl.java:379)
... 10 more




--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: SEVERE: Failed to resolve default logging config file: config/java.util.logging.properties

[monstereo]

Sorry for late
Here is the my project files:

-  Here is the config.xml  config.xml
<http://apache-ignite-users.70518.x6.nabble.com/file/t1901/config.xml>  
- Here is the pom.xml  pom.xml
<http://apache-ignite-users.70518.x6.nabble.com/file/t1901/pom.xml>  
- Here is the MainApp  MainApp.java
<http://apache-ignite-users.70518.x6.nabble.com/file/t1901/MainApp.java>  
- Here is the last file  IgniteFactory.java
<http://apache-ignite-users.70518.x6.nabble.com/file/t1901/IgniteFactory.java>  

ezhuravlev wrote
> Can you share this project so community can reproduce it?
> 
> 2018-08-07 11:04 GMT+03:00 monstereo 

> mehmetozanguven@

> :
> 
>> No i am not using spark, it is simply java project
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: SEVERE: Failed to resolve default logging config file: config/java.util.logging.properties

[monstereo]

No i am not using spark, it is simply java project



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: SEVERE: Failed to resolve default logging config file: config/java.util.logging.properties

[monstereo]

same error
when ı run ja file
java -DIGNITE_LOG_DIR=somePath/toBin/apache-ignite-fabric-2.5.0-bin/config
-jar DifferentHosts-1.0-SNAPSHOT.one-jar.jar
give me the same error Re: SEVERE: Failed to resolve default logging config
file: config/java.util.logging.properties

or this 
java -DIGNITE_LOG_DIR=somePath/toBin/apache-ignite-fabric-2.5.0-bin/config/
-jar DifferentHosts-1.0-SNAPSHOT.one-jar.jar

I have also copied logging.properties.config file to simple directory log
java -DIGNITE_LOG_DIR=somePath/Desktop/log/
-jar DifferentHosts-1.0-SNAPSHOT.one-jar.jar

does not work



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: SEVERE: Failed to resolve default logging config file: config/java.util.logging.properties

[monstereo]

no it does not work
there is java.util.logging.propeties file in my
apache-ignite-fabric-2.5.0-bin/config/

when I run the jar file via:
java
-DIGNITE_LOG_DIR=somePath/toBin/apache-ignite-fabric-2.5.0-bin/config/java.util.logging.properties
-jar DifferentHosts-1.0-SNAPSHOT.one-jar.jar
give me the same error SEVERE: Failed to resolve 

when I run the jar file via:
java -DIGNITE_HOME=somePath/toBin//apache-ignite-fabric-2.5.0-bin/ -jar
DifferentHosts-1.0-SNAPSHOT.one-jar.jar

give me this error:
java.lang.ClassNotFoundException:
org.apache.ignite.logger.java.JavaLoggerFileHandler


As I said early, when I run in intellij , there is no problem 



ezhuravlev wrote
> well, because you need to have config/java.util.logging.properties in
> IGNITE_HOME directory, or you can configure path to this file explicitly
> using IGNITE_LOG_DIR
> 
> 2018-08-07 10:18 GMT+03:00 monstereo 

> mehmetozanguven@

> :
> 
>> thanks,
>> I can solve this error via adding -DIGNITE_HOME in my vm option
>> But when I convert to the jar file, can not see the -DIGNITE_HOME
>> even if I say:
>> java -DIGNITE_HOME=pathToBin -jar jarName
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: SEVERE: Failed to resolve default logging config file: config/java.util.logging.properties

[monstereo]

thanks,
I can solve this error via adding -DIGNITE_HOME in my vm option
But when I convert to the jar file, can not see the -DIGNITE_HOME
even if I say:
java -DIGNITE_HOME=pathToBin -jar jarName



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Caused by: java.lang.ClassNotFoundException: org.apache.ignite.logger.slf4j.Slf4jLogger

[monstereo]

I have solved this one 
I am looking for an answer 
this

  



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

SEVERE: Failed to resolve default logging config file: config/java.util.logging.properties

[monstereo]

I can not solve this failed
log4j:WARN No appenders could be found for logger
(org.apache.ignite.internal.util.typedef.G).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for
more info.
Aug 07, 2018 9:27:28 AM java.util.logging.LogManager$RootLogger log
SEVERE: Failed to resolve default logging config file:
config/java.util.logging.properties

pom.xml:
 
org.apache.ignite
ignite-log4j
2.5.0


org.apache.ignite
ignite-slf4j
2.5.0


org.slf4j
slf4j-api
1.7.25


org.slf4j
slf4j-simple
1.7.25
test


config xml
 




.. default configuration




--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Caused by: java.lang.ClassNotFoundException: org.apache.ignite.logger.slf4j.Slf4jLogger

[monstereo]

I can not solve this problem
pom.xml:
 
org.apache.ignite
ignite-log4j
2.5.0


org.slf4j
slf4j-api
1.7.25


org.slf4j
slf4j-simple
1.7.25
test


ignite xml configuration





... default coniguration is here
http://apache-ignite-users.70518.x6.nabble.com/

Re: The Apache Ignite book - I have some confusion when reading?

[monstereo]

you have answered my all questions,
thanks...



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: The Apache Ignite book - I have some confusion when reading?

[monstereo]

last question is-> in replicated mode all nodes are primary node?


monstereo wrote
> Especially chapter 4 Architecture deep dive
> 
> Now: 
> 1) primary node is the node where we do igniteCache.put(2)="any string". I
> mean node which we put data in to cache is primary node?
> 
> 2) let's say we have primary node(includes some cache datas, cache name
> cache1), now we create another node, then we take the distributed
> cache(igniteCache.getOrCreateCache("cache1") and we put new element to the
> node igniteCache.put(3)="data", now this new node is also primary node?
> 
> 3) I have known that when client node wants to read cache, firstly it
> reads
> from primary node. But book says ->
> 
*
>   *  "up to 2.5 version, all read requests from the client node
> to replicated cache goes
> through the primary node, which can impact a severe performance issue. It
> was fixed as
> a bug20 and resolved in version 2.5"*.
*
> That's means, client can read data any backup node?(without going primary
> node)
> 
> 4) For data replication book says there are 2 forms ->
*
> *Master-slave
> Peer-to-peer*
*
> but there is no explanation for which ignite should use in default. Or how
> can i
> force to use one specific form?
> 
> 5) Book says that (for Peer-to-peer)->
*
> *The loss of any node does not prevent access to the data store.*
*
> Now, let's say I have one node which includes cache store factory xml
> configuration which updates database or get datas from database.
> Now, I create another node, but this node has no cache store factoy xml
> configuration. 
> When node which has  cache store factory xml configuration fails, other
> node(s) will be update database ?
> 
> 
> 
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: The Apache Ignite book - I have some confusion when reading?

[monstereo]

many thanks
for last question, I have tried on my laptops and found what I need.

srecon wrote
> Hi, 
> Let’s start at the beginning. There is no primary node in Ignite. When we
> say primary node (I will correct the term in the book soon), we mean the
> node that contains the master (prime/primary) copies of the keys or
> partitions.
> 
> 
> monstereo wrote
>> Especially chapter 4 Architecture deep dive
>> 
>> Now: 
>> 1) primary node is the node where we do igniteCache.put(2)="any string".
>> I
>> mean node which we put data in to cache is primary node?
> 
> If you have a single node cluster, the answer is yes. However, if you have
> a
> multi-node cluster, the answer is NO, because you can execute
> igniteCache.put(2)="any string" command through Ignite thin client (REST,
> Java thin client, etc.,) or the Ignite client node.
> Primary node of the keys (actually Ignite uses partitions to store keys)
> is
> the node that stores a master copy of the key-value.
> In the PARTITIONED mode, Ignite stores data across the entire cluster. In
> this mode, one of the nodes contains master copy of the data and rest of
> the
> nodes contains a backup copy of the same data (depends on BACKUP value
> configuration)
> In the REPLICATED mode, each node contains the same data for the
> particular
> cache.
> 
>  
> monstereo wrote
>> Especially chapter 4 Architecture deep dive
>> 
>> 2) let's say we have primary node(includes some cache datas, cache name
>> cache1), now we create another node, then we take the distributed
>> cache(igniteCache.getOrCreateCache("cache1") and we put new element to
>> the
>> node igniteCache.put(3)="data", now this new node is also primary node?
> 
> In the PARTITIONED cache mode, the second node will contain 50% of the
> master copies of the cache named "cache1".
> 
> 
> monstereo wrote
>> Especially chapter 4 Architecture deep dive
>> 
>> 3) I have known that when client node wants to read cache, firstly it
>> reads
>> from primary node. But book says ->
>> 
> *
>>   *  "up to 2.5 version, all read requests from the client node
>> to replicated cache goes
>> through the primary node, which can impact a severe performance issue. It
>> was fixed as
>> a bug20 and resolved in version 2.5"*.
> *
>> That's means, client can read data any backup node?(without going primary
>> node)
> 
> Yes, you can explicitly read backup copies of the data, see the method
> CacheConfiguration.isReadFromBackup(). Anyway, it's not recommended
> because
> you may have stale data read (a value has already been updated on primary
> but not updated in backups yet).
> 
> 
> monstereo wrote
>> Especially chapter 4 Architecture deep dive
>> 
>> 4) For data replication book says there are 2 forms ->
> *
>> *Master-slave
>> Peer-to-peer*
> *
>> but there is no explanation for which ignite should use in default. Or
>> how
>> can i
>> force to use one specific form?
> 
> Quote from the book "Apache Ignite does not have any master node and
> therefore does not use master-slave replication for distributing data."
> 
> Apache Ignite uses peer-to-peer replication strategies, and you don't need
> to specify it explicitly.
> 
> 
> 
> monstereo wrote
>> Especially chapter 4 Architecture deep dive
>> 
>> 5) Book says that (for Peer-to-peer)->
> *
>> *The loss of any node does not prevent access to the data store.*
> *
>> Now, let's say I have one node which includes cache store factory xml
>> configuration which updates database or get datas from database.
>> Now, I create another node, but this node has no cache store factoy xml
>> configuration. 
>> When node which has  cache store factory xml configuration fails, other
>> node(s) will be update database ?
> 
> Sorry, I could not get your question, please try to explain the use case
> in
> details.
> 
> P.S. I do not always pay attention to Ignite forum. To get a quick
> response,
> please send me any private message or copy the question to 

> srecon@

> .
> 
> Best regards
>   Shamim 
> 
> 
> 
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Specify Port for discovery?Stop the discovery?

[monstereo]

I don't want node2 to connect node1. But it is always connectting. 
Here is the node1 xml









127.0.0.1:48500..48520





 


Here is the node2 xml








192.168.122.1:47500..47509







*note that 192.168.122.1 is the node1 ip address*



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

The Apache Ignite book - I have some confusion when reading?

[monstereo]

Especially chapter 4 Architecture deep dive

Now: 
1) primary node is the node where we do igniteCache.put(2)="any string". I
mean node which we put data in to cache is primary node?
2) let's say we have primary node(includes some cache datas, cache name
cache1), now we create another node, then we take the distributed
cache(igniteCache.getOrCreateCache("cache1") and we put new element to the
node igniteCache.put(3)="data", now this new node is also primary node?
3) I have known that when client node wants to read cache, firstly it reads
from primary node. But book says ->
  *  "up to 2.5 version, all read requests from the client node
to replicated cache goes
through the primary node, which can impact a severe performance issue. It
was fixed as
a bug20 and resolved in version 2.5"*.
That's means, client can read data any backup node(without going primary
node)
4) For data replication book says there are 2 forms ->
*Master-slave
Peer-to-peer*
but there is no explanation for which ignite should default. Or how can i
force to one specific form?
5) Book says that (for Peer-to-peer)->
*The loss of any node does not prevent access to the data store.*
Now, let's say I have one node which includes cache store factory xml
configuration which updates database or get datas from database.
Now, I create another node, but this node has no cache store factoy xml
configuration. 
When node which has  cache store factory xml configuration fails, other
node(s) will be update database ?



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: IgniteMessaging, What am I doing wrong?

[monstereo]

thanks,
When I want to send messages from server to client, it works
probably, there were a problem as you stated.

May I ask :
Let's say server send a messages to client ("hello")
When I create another client after  seconds, minutes vs.. , this new client
will see this messages?
Same question for events?



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

IgniteMessaging, What am I doing wrong?

[monstereo]

I want to send message to client nodes from server nodes, and client nodes
will take this message and print it.

Here is the server nodes
 
public static void main {
  Ignite server = //start ignite with default config path
ClusterGroup clientNodes = server.cluster().forClients();
 IgniteMessaging messaging = server.message(clientNodes);
messaging.send("ServerTopic", "hello");
}

Here is the client node
public static void main ...{
Ignite client = //start ignite client with default config
ClusterGroup clientNodes = client.cluster().forClients();
IgniteMessaging serverTopic = client.message(clientNodes);
consumerTopic.remoteListen("ServerTopic", (nodeId, message) ->{
System.out.println("Severr with id:" + nodeId +"\nsend this
message : " + message);
return true;
});
}

But I can not see the message on client nodes.
(I run client first, then run the server node(s))



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: CacheMetrics does not show the correct results

[monstereo]

when i added

TimeUnit.SECONDS.sleep(5);

this line, it solved.

But if we had more datas, maybe sleep time would be larger



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

CacheMetrics does not show the correct results

[monstereo]

code that is generated cache values

public static void populateCache(IgniteCache igniteCache){
for (int i = 0; i < 1; i++){
igniteCache.put(i, String.valueOf(i));
}
}

public static void main(String[] args) {
Ignite node1 = Ignition.start("defaultPath);
   

CacheConfiguration cacheConfiguration = new CacheConfiguration();
cacheConfiguration.setName("sampleCache");
cacheConfiguration.setCacheMode(CacheMode.REPLICATED);
cacheConfiguration.setStatisticsEnabled(true);
IgniteCache igniteCache =
node1.getOrCreateCache(cacheConfiguration);

populateCache(igniteCache);
System.out.println(igniteCache.size());



Here is the another ignite node :
public static void main(String[] args) throws InterruptedException {
Ignite node2 =
IgniteFactory.createIgniteNodeWithDefaultConfiguration("s");

IgniteCache igniteCache = node2.getOrCreateCache("sampleCache");
CacheMetrics cacheMetrics = igniteCache.metrics();
System.out.println(cacheMetrics.getOffHeapBackupEntriesCount());


First I run the node1, and wait until see output (cache size)
then, I run the node2, but offheap backup entry count returns 0.
(after a seconds, I run the node2 again (creating new node), then offheap
backup entry count returns 10062 -and other different values)

What is the reason for this?
How can i solve it? (I want to see 1 backup when I run the node2 first
time)



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

RE: What is the difference between TcpCommunicationSpi ?

[monstereo]

sorry,
there is no reproducure

Stanislav Lukyanov wrote
> Please don’t send messages like “?”. Mailing list is not a chatroom,
> messages need to be complete and meaningful.
> 
> Reproducer is a code snippet or project that can be run standalone to
> reproduce the problem.
> The behavior you see isn’t expected nor known, so we need to see it before
> we can comment on it.
> So, do you have a reproducer?
> 
> Stan
> 
> From: monstereo
> Sent: 25 июля 2018 г. 17:13
> To: 

> user@.apache

> Subject: Re: What is the difference between TcpCommunicationSpi
>  ?
> 
> ?
> 
> 
> ezhuravlev wrote
>>>Do you have reproducer?
>> 
>> 
>> 2018-07-25 12:25 GMT+03:00 monstereo 
> 
>> mehmetozanguven@
> 
>> :
>> 
>>> Yes same machine
>>>
>>> ezhuravlev wrote
>>> >>What is the difference between TcpCommunicationSpi &
>>> TcpTcpDiscoverySpi
>>> ?
>>> > https://stackoverflow.com/questions/37936833/difference-between-
>>> tcpcommunicationspicommunicationspi-and-tcpdiscoveryspidis
>>> >
>>> >>Every node I have created has different tcp discovery local port but
>>> same
>>> > tcp commication port. Why?
>>> > Do you start nodes on the same machine? Do you have reproducer?
>>> >
>>> > Evgenii
>>> >
>>> > 2018-07-20 13:37 GMT+03:00 monstereo 
>>>
>>> > mehmetozanguven@
>>>
>>> > :
>>> >
>>> >> Here is the config file
>>> >> 
>>> >>
>>> > 
>> 
> 
>>> >>
>>> > 
>> 
> >
>>
>>  >>
>>> >  class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
>>> >>
>>> >>
>>> > 
>> 
> 
>>> >>
>>> >>
>>> > 
>> 
> 
>>> >> .
>>> >>
>>> > 
>> 
> 
>>> >>
>>> >>
>>> > 
>> 
> >
>>
>>  >>
>>> >  class="org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi">
>>> >>
>>> >>
>>> > 
>> 
> 
>>> >>
>>> >>
>>> > 
>> 
> 
>>> >>
>>> >>
>>> >>
>>> >> Every node I have created has different tcp discovery local port but
>>> same
>>> >> tcp commication port. Why?
>>> >>
>>> >>
>>> >>
>>> >> --
>>> >> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>> >>
>>>
>>>
>>>
>>>
>>>
>>> --
>>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>>
> 
> 
> 
> 
> 
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: What is the difference between TcpCommunicationSpi & TcpTcpDiscoverySpi ?

[monstereo]

??

ezhuravlev wrote
>>Do you have reproducer?
> 
> 
> 2018-07-25 12:25 GMT+03:00 monstereo 

> mehmetozanguven@

> :
> 
>> Yes same machine
>>
>> ezhuravlev wrote
>> >>What is the difference between TcpCommunicationSpi & TcpTcpDiscoverySpi
>> ?
>> > https://stackoverflow.com/questions/37936833/difference-between-
>> tcpcommunicationspicommunicationspi-and-tcpdiscoveryspidis
>> >
>> >>Every node I have created has different tcp discovery local port but
>> same
>> > tcp commication port. Why?
>> > Do you start nodes on the same machine? Do you have reproducer?
>> >
>> > Evgenii
>> >
>> > 2018-07-20 13:37 GMT+03:00 monstereo 
>>
>> > mehmetozanguven@
>>
>> > :
>> >
>> >> Here is the config file
>> >> 
>> >>
>> > 
> 
>> >>
>> > 
> >
>  >>
>> >  class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
>> >>
>> >>
>> > 
> 
>> >>
>> >>
>> > 
> 
>> >> .
>> >>
>> > 
> 
>> >>
>> >>
>> > 
> >
>  >>
>> >  class="org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi">
>> >>
>> >>
>> > 
> 
>> >>
>> >>
>> > 
> 
>> >>
>> >>
>> >>
>> >> Every node I have created has different tcp discovery local port but
>> same
>> >> tcp commication port. Why?
>> >>
>> >>
>> >>
>> >> --
>> >> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>> >>
>>
>>
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: What is the difference between TcpCommunicationSpi & TcpTcpDiscoverySpi ?

[monstereo]

?


ezhuravlev wrote
>>Do you have reproducer?
> 
> 
> 2018-07-25 12:25 GMT+03:00 monstereo 

> mehmetozanguven@

> :
> 
>> Yes same machine
>>
>> ezhuravlev wrote
>> >>What is the difference between TcpCommunicationSpi & TcpTcpDiscoverySpi
>> ?
>> > https://stackoverflow.com/questions/37936833/difference-between-
>> tcpcommunicationspicommunicationspi-and-tcpdiscoveryspidis
>> >
>> >>Every node I have created has different tcp discovery local port but
>> same
>> > tcp commication port. Why?
>> > Do you start nodes on the same machine? Do you have reproducer?
>> >
>> > Evgenii
>> >
>> > 2018-07-20 13:37 GMT+03:00 monstereo 
>>
>> > mehmetozanguven@
>>
>> > :
>> >
>> >> Here is the config file
>> >> 
>> >>
>> > 
> 
>> >>
>> > 
> >
>  >>
>> >  class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
>> >>
>> >>
>> > 
> 
>> >>
>> >>
>> > 
> 
>> >> .
>> >>
>> > 
> 
>> >>
>> >>
>> > 
> >
>  >>
>> >  class="org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi">
>> >>
>> >>
>> > 
> 
>> >>
>> >>
>> > 
> 
>> >>
>> >>
>> >>
>> >> Every node I have created has different tcp discovery local port but
>> same
>> >> tcp commication port. Why?
>> >>
>> >>
>> >>
>> >> --
>> >> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>> >>
>>
>>
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: What is the difference between TcpCommunicationSpi & TcpTcpDiscoverySpi ?

[monstereo]

Yes same machine

ezhuravlev wrote
>>What is the difference between TcpCommunicationSpi & TcpTcpDiscoverySpi ?
> https://stackoverflow.com/questions/37936833/difference-between-tcpcommunicationspicommunicationspi-and-tcpdiscoveryspidis
> 
>>Every node I have created has different tcp discovery local port but same
> tcp commication port. Why?
> Do you start nodes on the same machine? Do you have reproducer?
> 
> Evgenii
> 
> 2018-07-20 13:37 GMT+03:00 monstereo 

> mehmetozanguven@

> :
> 
>> Here is the config file
>> 
>> 
> 
>> 
> >
>  class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
>>
>> 
> 
>>
>> 
> 
>> .
>> 
> 
>>
>> 
> >
>  class="org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi">
>>
>> 
> 
>>
>> 
> 
>>
>>
>>
>> Every node I have created has different tcp discovery local port but same
>> tcp commication port. Why?
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Waiting too long, to load 7k datas to cache.... And Client gets null value

[monstereo]

thanks, ilya 

however, client does not wait until backup has complete. Here is the my
codes:

First I create node1, and wait until cache size is 2.000.000
Then i run another nodes (node2, client) and yes client will wait until 2
node2 runs
But i want client to wait until backup operation is done.

Because, when I use GridGain web console:
 even if I see this output "Now consumer has all backup
" + igniteCache.size()"
 in grid console, backup is creating, (its number is
increasing -> 100k , 805k , 1.3M ... 2M)
 and backup is creating, client can get data(of course
gets correct result, because cache has been created before by node1)



For node 1(Create 2.000.000 datas in cache)

public static void populateCache(IgniteCache igniteCache){
for (int i = 0; i < 200; i++){
igniteCache.put(i, String.valueOf(i));
}
}

public static void main(String[] args) {
Ignite node1 = Ignition.start(defaultconfigpath);
IgniteCountDownLatch igniteCountDownLatch =
publisher.countDownLatch(
"simpleLatch", 2, false, true);


CacheConfiguration cacheConfiguration = new CacheConfiguration();
cacheConfiguration.setName("sampleCache");
cacheConfiguration.setCacheMode(CacheMode.REPLICATED);
IgniteCache igniteCache =
publisher.getOrCreateCache(cacheConfiguration);

populateCache(igniteCache);
System.out.println(igniteCache.size());

}

here is the node 2:

public static void main(String[] args) {
Ignite node2 =Ignition.start(defaultconfigpath);

IgniteCache igniteCache = consumer.getOrCreateCache("sampleCache");

IgniteCountDownLatch latch = consumer.countDownLatch(
"simpleLatch", 2, false, true);

if (igniteCache.size() == 200){
System.out.println("Now consumer has all backup " +
igniteCache.size());
System.out.println("Now decrease the latch");
latch.countDown();
}

}


here is the client:

public static void main(String[] args) {
Ignite client = Ignition.start(defaultconfigpath);
Ignition.setClientMode(true);

IgniteCountDownLatch latch = client.countDownLatch(
"simpleLatch", 2, false, true);

System.out.println("Client is wait to latch");

latch.await();

System.out.println("Now client can get values");
IgniteCache igniteCache = client.getOrCreateCache("sampleCache");
System.out.println(igniteCache.get(79));
}


ilya.kasnacheev wrote
> Hello!
> 
> You can use ignite.countDownLatch(). I believe we've already discussed
> this
> approach.
> 
> Regards,
> 
> -- 
> Ilya Kasnacheev
> 
> 2018-07-24 18:14 GMT+03:00 monstereo 

> mehmetozanguven@

> :
> 
>> ??
>>
>> monstereo wrote
>> > thank you,
>> > As you stated, it is about my memory configuration, I solved it. (When
>> I
>> > increase the memory)
>> >
>> > But can you explain external synch. part for " "cache is not ready" if
>> the
>> > cache is already created but not populated yet. You need external sync
>> > here."
>> >
>> > Which method ignite provides for this "cache is not ready". (I am
>> looking
>> > for -> "client can not run the get method, until cache is ready.")
>> >
>> >
>> > ilya.kasnacheev wrote
>> >> Hello!
>> >>
>> >> Can you please provide the thread dump while running this code?
>> >>
>> >> Note that 10M is a very very small number for a memory model and it
>> might
>> >> affect your case.
>> >>
>> >> Also note that cache.get() should absolutely not return "cache is not
>> >> ready" if the cache is already created but not populated yet. You need
>> >> external sync here.
>> >>
>> >> Regards,
>> >>
>> >>
>> >> --
>> >> Ilya Kasnacheev
>> >>
>> >> 2018-07-23 11:22 GMT+03:00 monstereo 
>> >
>> >> mehmetozanguven@
>> >
>> >> :
>> >>
>> >>> Here is the config file:
>> >>>
>> >>
>> > 
> 
>> >>>
>> >>
>> > 
> >
>  >>
>> >>
>> >>  class="org.apache.ignite.configuration.DataStorageConfiguration">
>> >>>
>> >>
>> > 
> 
>> >>>
>> >>
>&g

Re: Waiting too long, to load 7k datas to cache.... And Client gets null value

[monstereo]

??

monstereo wrote
> thank you,
> As you stated, it is about my memory configuration, I solved it. (When I
> increase the memory)
> 
> But can you explain external synch. part for " "cache is not ready" if the
> cache is already created but not populated yet. You need external sync
> here."
> 
> Which method ignite provides for this "cache is not ready". (I am looking
> for -> "client can not run the get method, until cache is ready.")
> 
> 
> ilya.kasnacheev wrote
>> Hello!
>> 
>> Can you please provide the thread dump while running this code?
>> 
>> Note that 10M is a very very small number for a memory model and it might
>> affect your case.
>> 
>> Also note that cache.get() should absolutely not return "cache is not
>> ready" if the cache is already created but not populated yet. You need
>> external sync here.
>> 
>> Regards,
>> 
>> 
>> -- 
>> Ilya Kasnacheev
>> 
>> 2018-07-23 11:22 GMT+03:00 monstereo 
> 
>> mehmetozanguven@
> 
>> :
>> 
>>> Here is the config file:
>>>  
>> 
> 
>>> 
>> 
> >
>>
>>  class="org.apache.ignite.configuration.DataStorageConfiguration">
>>> 
>> 
> 
>>> 
>> 
> 
>>> 
>> 
> >
>>
>>  class="org.apache.ignite.configuration.DataRegionConfiguration">
>>> 
>> 
> 
>>> 
>> 
> >
>>
>>  value="#{10L*1024*1024}"/>
>>> 
>> 
> >
>>
>>  value="#{10L*1024*1024}"/>
>>> 
>> 
> >
>>
>>  value="RANDOM_2_LRU"/>
>>> 
>> 
> >
>>
>>  value="0.5"/>
>>> 
>> 
> 
>>> 
>> 
> 
>>> 
>> 
> 
>>> 
>> 
> 
>>> 
>> 
> 
>>>
>>> 
>> 
> 
>>> 
>> 
> >
>>
>>  class="org.apache.ignite.configuration.CacheConfiguration">
>>>
>>> 
>> 
> 
>>>
>>> 
>> 
> 
>>>
>>> 
>> 
> 
>>> 
>> 
> 
>>> 
>> 
> 
>>>
>>>
>>> Here is the main app
>>> public static void populateCache(IgniteCache igniteCache){
>>> for (int i = 0; i < 10; i++){
>>> igniteCache.put(i, String.valueOf(i));
>>> }
>>> }
>>>
>>> public static void main(String[] args) {
>>> Ignite igniteNode =
>>> IgniteFactory.createIgniteNodeWithSpecificConfiguration("s",
>>> configPath);
>>> IgniteConfiguration igniteConfiguration =
>>> igniteNode.configuration();
>>> IgniteCache igniteCache = igniteNode.getOrCreateCache("
>>> testCache");
>>> populateCache(igniteCache);
>>> System.out.println(igniteCache.size());
>>>
>>> }
>>>
>>> when i changed to i<7000 (in  populateCache method),  server node
>>> appears(I
>>> mean, i can see "[11:13:09] Topology snapshot [ver=1, servers=1,
>>> clients=0,
>>> CPUs=4, offheap=1.2GB, heap=1.3GB]") but too wait to write
>>> System.out.println(igniteCache.size());
>>>
>>> Now at the same time I have created client node :
>>>
>>>   Ignite client =
>>> IgniteFactory.createIgniteNodeWithSpecificConfiguration("c", cluster_1);
>>> IgniteCache igniteCache = client.getOrCreateCache("testCache");
>>> System.out.println(igniteCache.get(6999));
>>>
>>> this returns null,
>>>
>>> it should not return null -> it should return::
>>> * cache is not ready
>>> * or wait until cache is ready and get the result which is 6999
>>>
>>>
>>>
>>> --
>>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>>
> 
> 
> 
> 
> 
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Random-LRU-2 ?

[monstereo]

I could not understand this part "MIN(timestamp1, timestamp2) for further
comparing"

That's means :

Algorithm select randomly 5 indexes(let's say it choose indexes 4, 12, 5, 1,
3) and takes the index MIN(timestamp1, timestamp2) (let's say index 5)

Then it evaluates |timestamp1 - timestamp2| for every other indexes.

Then compare them with index 5.

Then it will be evicted the index which value of ( (timestamp1 - timestamp2)
- MIN(timestamp1, timestamp2) ) is the highest?



mcherkasov wrote
>>For random-lru and random-lru-2, algorithm randomly selects 5 indexes. Why
> 5? 
> well,  I don't know about how this number has been chosen. The only I can
> say it works fine.
> 
>>Can I change this number? 
> there's no way to configure it.
> 
>>And we evict the index which |last_1 - last_2| is max? Am i correct? 
> Nope, Random LRU2 tracks two last recently used timestamps and takes
> MIN(timestamp1, timestamp2) for further comparing. 
> 
>>What is the best advantages over random-lru to random-lru-2(vica-verse)? 
> see the doc about this, it explicitly explains this:
> https://apacheignite.readme.io/docs/evictions#section-random-2-lru
> 
> 
> 
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Waiting too long, to load 7k datas to cache.... And Client gets null value

[monstereo]

thank you,
As you stated, it is about my memory configuration, I solved it. (When I
increase the memory)

But can you explain external synch. part for " "cache is not ready" if the
cache is already created but not populated yet. You need external sync
here."

Which method ignite provides for this "cache is not ready". (I am looking
for -> "client can not run the get method, until cache is ready.")


ilya.kasnacheev wrote
> Hello!
> 
> Can you please provide the thread dump while running this code?
> 
> Note that 10M is a very very small number for a memory model and it might
> affect your case.
> 
> Also note that cache.get() should absolutely not return "cache is not
> ready" if the cache is already created but not populated yet. You need
> external sync here.
> 
> Regards,
> 
> 
> -- 
> Ilya Kasnacheev
> 
> 2018-07-23 11:22 GMT+03:00 monstereo 

> mehmetozanguven@

> :
> 
>> Here is the config file:
>>  
> 
>> 
> >
>  class="org.apache.ignite.configuration.DataStorageConfiguration">
>> 
> 
>> 
> 
>> 
> >
>  class="org.apache.ignite.configuration.DataRegionConfiguration">
>> 
> 
>> 
> >
>  value="#{10L*1024*1024}"/>
>> 
> >
>  value="#{10L*1024*1024}"/>
>> 
> >
>  value="RANDOM_2_LRU"/>
>> 
> >
>  value="0.5"/>
>> 
> 
>> 
> 
>> 
> 
>> 
> 
>> 
> 
>>
>> 
> 
>> 
> >
>  class="org.apache.ignite.configuration.CacheConfiguration">
>>
>> 
> 
>>
>> 
> 
>>
>> 
> 
>> 
> 
>> 
> 
>>
>>
>> Here is the main app
>> public static void populateCache(IgniteCache igniteCache){
>> for (int i = 0; i < 10; i++){
>> igniteCache.put(i, String.valueOf(i));
>> }
>> }
>>
>> public static void main(String[] args) {
>> Ignite igniteNode =
>> IgniteFactory.createIgniteNodeWithSpecificConfiguration("s", configPath);
>> IgniteConfiguration igniteConfiguration =
>> igniteNode.configuration();
>> IgniteCache igniteCache = igniteNode.getOrCreateCache("
>> testCache");
>> populateCache(igniteCache);
>> System.out.println(igniteCache.size());
>>
>> }
>>
>> when i changed to i<7000 (in  populateCache method),  server node
>> appears(I
>> mean, i can see "[11:13:09] Topology snapshot [ver=1, servers=1,
>> clients=0,
>> CPUs=4, offheap=1.2GB, heap=1.3GB]") but too wait to write
>> System.out.println(igniteCache.size());
>>
>> Now at the same time I have created client node :
>>
>>   Ignite client =
>> IgniteFactory.createIgniteNodeWithSpecificConfiguration("c", cluster_1);
>> IgniteCache igniteCache = client.getOrCreateCache("testCache");
>> System.out.println(igniteCache.get(6999));
>>
>> this returns null,
>>
>> it should not return null -> it should return::
>> * cache is not ready
>> * or wait until cache is ready and get the result which is 6999
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Waiting too long, to load 7k datas to cache.... And Client gets null value

[monstereo]

Here is the config file:
 



























Here is the main app
public static void populateCache(IgniteCache igniteCache){
for (int i = 0; i < 10; i++){
igniteCache.put(i, String.valueOf(i));
}
}

public static void main(String[] args) {
Ignite igniteNode =
IgniteFactory.createIgniteNodeWithSpecificConfiguration("s", configPath);
IgniteConfiguration igniteConfiguration =
igniteNode.configuration();
IgniteCache igniteCache = igniteNode.getOrCreateCache("testCache");
populateCache(igniteCache);
System.out.println(igniteCache.size());

}

when i changed to i<7000 (in  populateCache method),  server node appears(I
mean, i can see "[11:13:09] Topology snapshot [ver=1, servers=1, clients=0,
CPUs=4, offheap=1.2GB, heap=1.3GB]") but too wait to write 
System.out.println(igniteCache.size());

Now at the same time I have created client node :

  Ignite client =
IgniteFactory.createIgniteNodeWithSpecificConfiguration("c", cluster_1);
IgniteCache igniteCache = client.getOrCreateCache("testCache");
System.out.println(igniteCache.get(6999));

this returns null,

it should not return null -> it should return::
* cache is not ready
* or wait until cache is ready and get the result which is 6999



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Random-LRU-2 ?

[monstereo]

For random-lru and random-lru-2, algorithm randomly selects 5 indexes. Why 5?
Can I change this number?

And I am a little bit confused in random-lru-2. This case works:

For selecting 5 indexes, we look the last 2 timestamp(let's say last_1 and
last_2) values for each indexes.
And we evict the index which |last_1 - last_2| is max? Am i correct?

What is the best advantages over random-lru to random-lru-2(vica-verse)?



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: What is the difference between TcpCommunicationSpi & TcpDiscoverySpi ?

[monstereo]

Then localportrange in tcp communication determines how many nodes will
communicate each other?

Because in tcp disvocery, each node is getting different port number with
range specifies in localportrange

Mikael wrote
> https://stackoverflow.com/questions/37936833/difference-between-tcpcommunicationspicommunicationspi-and-tcpdiscoveryspidis
> 
> 
> Den 2018-07-20 kl. 12:57, skrev monstereo:
>> Is there anyone who can answer?
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: What is the difference between TcpCommunicationSpi & TcpDiscoverySpi ?

[monstereo]

Is there anyone who can answer?



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

What is the difference between TcpCommunicationSpi & TcpTcpDiscoverySpi ?

[monstereo]

Here is the config file 







.










Every node I have created has different tcp discovery local port but same
tcp commication port. Why? 



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: LRU policy, on heap - off heap size ?

[monstereo]

thanks

slava.koptilin wrote
> Hello,
> 
> Yep, it is expected behavior. You are using on-heap eviction policy and
> so,
> this policy removes the cache entries from Java heap only. The entries
> stored in the off-heap region of the memory are not affected.
> You can find a comprehensive description here:
> https://apacheignite.readme.io/docs/evictions#section-java-heap-cache
> 
> Thanks.
> 
> 
> чт, 19 июл. 2018 г. в 11:12, monstereo 

> mehmetozanguven@

> :
> 
>> Here is the my lru configuration
>>
>> ...
>> ccfg.setOnheapCacheEnabled(true);
>> ccfg.setEvictionPolicyFactory(new LruEvictionPolicyFactoryInteger,
>  Person>(2));
>> ...
>>
>> When I want to load 3 datas to cache, ignite console shows me
>> <
>> http://apache-ignite-users.70518.x6.nabble.com/file/t1901/ignite-forum-1.png>
>>
>>
>> 2 on heap and 3 off heap
>>
>> why it is 2 on heap 1 off heap? Is it ignite features?
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

LRU policy, on heap - off heap size ?

[monstereo]

Here is the my lru configuration

...
ccfg.setOnheapCacheEnabled(true);
ccfg.setEvictionPolicyFactory(new LruEvictionPolicyFactory(2));
...

When I want to load 3 datas to cache, ignite console shows me
 

2 on heap and 3 off heap

why it is 2 on heap 1 off heap? Is it ignite features?



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

CRUD operation on Hibernate L2 Cache ?

[monstereo]

I can run the example on github for hibernate l2 cache with ignite. And also
I am adding the new data to mydatabase like this command::
 
User user = new User("jedi", "Luke", "Skywalker");

 user.getPosts().add(new Post(user, "Let the Force be with you."));

   ses.save(user);

When I want to add new element to cache, it will also update the database.
When I want to update any element in cache, it will also update the
database.
When I want to delete any element in cache, it will also delete the element
from database.

How I can do that? I am allowed to use igniteCache.get, put, delete ?? 




--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Port Assigned? Work on specific Node?

[monstereo]

There is no cache configuration in these xml file, but assume that in
cluster1 configuration there is cache configuration which mode is REPLICATED 
and operation is TRANSACTIONAL



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Port Assigned? Work on specific Node?

[monstereo]

Hey here is the full scenario, I hope it will be clear:

I have 2 clusters
Each cluster has own different cache, let's say in cluster 1, there is cache
named "cluster1cache". (We can assume that no cache in cluster 2)
And I want to copy these cache to cluster2, but when copying occurs, client
should not get interact with cluster2, or cluster2 should say "I'm busy". 

Here is the my cluster1 and cluster2 config file. (I can create seperate
nodes for each clusterr -I have tested in grid gain console-)

cluster1-configuration.xml
<http://apache-ignite-users.70518.x6.nabble.com/file/t1901/cluster1-configuration.xml>
  
cluster2-configuration.xml
<http://apache-ignite-users.70518.x6.nabble.com/file/t1901/cluster2-configuration.xml>
  


ilya.kasnacheev wrote
> Hello!
> 
> I can address the immediate questions that you are having, but I'm afraid
> that you will be only getting further away from optimal solution of your
> case.
> 
> What is your case? Can you please tell us more about the scenario that you
> are trying to implement?
> 
> Regards,
> 
> -- 
> Ilya Kasnacheev
> 
> 2018-07-16 18:26 GMT+03:00 monstereo 

> mehmetozanguven@

> :
> 
>> I have read the links that you have shared, but there is no information
>> about
>> different clusters
>>
>> I have found Ignite native persistence, can it be a solution for my case?
>>
>> And I have allow to create different cluster in my laptop?
>>
>> ilya.kasnacheev wrote
>> > Hello!
>> >
>> > I think you could use ContinuousQuery
>> > https://apacheignite.readme.io/docs/continuous-queries; (with
>> > initial
>> > query) to copy all data from cache in one cluster to cache in another
>> > cluster.
>> > It will also take care of the situation where cache on node1 is changed
>> > while it is being copied.
>> > If that is not a concern, a simple ScanQuery
>> > https://apacheignite.readme.io/docs/cache-queries#scan-queries;
>> > will do.
>> >
>> >
>> > As for signalling client when it is appropriate to read cache from
>> node2,
>> > you could use CountDownLatch. Just always await() it in client, and on
>> > server countDown() it once all data is copied.
>> >
>> > Regards,
>> > Ilya.
>> >
>> > --
>> > Ilya Kasnacheev
>> >
>> > 2018-07-16 16:42 GMT+03:00 monstereo 
>>
>> > mehmetozanguven@
>>
>> > :
>> >
>> >> OMG!!!
>> >>
>> >> Yep, If there are belonging to different cluster, there is  way to
>> copy
>> >> caches data? Especially I am looking for ignite features.
>> >> Now one cluster has 1 datas
>> >> I will copy these datas to another cluster
>> >>
>> >>
>> >> Sorry man, I forget to write this.
>> >>
>> >>
>> >>
>> >>
>> >>
>> >> --
>> >> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>> >>
>>
>>
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Port Assigned? Work on specific Node?

[monstereo]

I have read the links that you have shared, but there is no information about
different clusters

I have found Ignite native persistence, can it be a solution for my case?

And I have allow to create different cluster in my laptop?

ilya.kasnacheev wrote
> Hello!
> 
> I think you could use ContinuousQuery
> https://apacheignite.readme.io/docs/continuous-queries; (with
> initial
> query) to copy all data from cache in one cluster to cache in another
> cluster.
> It will also take care of the situation where cache on node1 is changed
> while it is being copied.
> If that is not a concern, a simple ScanQuery
> https://apacheignite.readme.io/docs/cache-queries#scan-queries;
> will do.
> 
> 
> As for signalling client when it is appropriate to read cache from node2,
> you could use CountDownLatch. Just always await() it in client, and on
> server countDown() it once all data is copied.
> 
> Regards,
> Ilya.
> 
> -- 
> Ilya Kasnacheev
> 
> 2018-07-16 16:42 GMT+03:00 monstereo 

> mehmetozanguven@

> :
> 
>> OMG!!!
>>
>> Yep, If there are belonging to different cluster, there is  way to copy
>> caches data? Especially I am looking for ignite features.
>> Now one cluster has 1 datas
>> I will copy these datas to another cluster
>>
>>
>> Sorry man, I forget to write this.
>>
>>
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Port Assigned? Work on specific Node?

[monstereo]

OMG!!!

Yep, If there are belonging to different cluster, there is  way to copy
caches data? Especially I am looking for ignite features.
Now one cluster has 1 datas
I will copy these datas to another cluster


Sorry man, I forget to write this.





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Port Assigned? Work on specific Node?

[monstereo]

thanks, but this is not the answer that I expected,
maybe this scenario can be more understandable:

1 cache is in node1,
okey, node2 is created and node2 has copy of the node1(and node2 will not be
ready until copy is done!!)
now in node2 there is cache which name is "myCache" and I iterates over
node1 cache and i am putting datas to "myCache"
when putting occuring, client node should not say myCache.get(9500), it
should wait or i say to client, cache is not ready.


Let's assume that client will always looks "myCache" not the node1 cache


ilya.kasnacheev wrote
> Hello!
> 
> I have a feeling that you are trying to perform a manual sunset:
> reimplement something which is a part of core functionality and always
> provided out of box.
> 
> * Apache Ignite will read values from primary node only unless
> "readFromBackup" property is set.
> * Anyway, Apache Ignite will not try to read values from partition on node
> where it's not completely rebalanced yet.
> * In general, Apache Ignite will make sure that you're getting relevant
> and
> fresh data from cache.
> 
> Regards,
> 
> -- 
> Ilya Kasnacheev
> 
> 2018-07-16 15:59 GMT+03:00 monstereo 

> mehmetozanguven@

> :
> 
>> thanks for your understanding,
>> Last question,
>> I want to use data rebalancing, because I have scenario like this:
>>
>> let's say node 1 has 1 datas in its caches. (Which cache mode is
>> REPLICATED)
>> Now I will invoke another node2, then node2 will copy of node1's cache
>> datas.
>> But when copying occuring, if any client node wants to get data from
>> cache
>> via node2, I should say "cache is not ready" or node2 should be
>> accessible
>> after it has all datas.
>>
>> I though that I can use data rebalancing, that's why i am interested in
>> events. But, a few minutes ago, I have noticed I can not get
>> CacheRebalanceEVENT, because of replicated mode. (I can catch other
>> events
>> for example EVT_CACHE_OBJECT_PUT.
>>
>> Now what can i do?
>>
>> here is the cache events in xml file
>>
>>
>> 
> >
>  static-field="org.apache.ignite.events.EventType.EVT_CACHE_OBJECT_PUT"/>
>> 
> >
>  static-field="org.apache.ignite.events.EventType.EVT_CACHE_OBJECT_READ"/>
>> 
> >
>  static-field="org.apache.ignite.events.EventType.EVT_
>> CACHE_OBJECT_REMOVED"/>
>> 
> >
>  static-field="org.apache.ignite.events.EventType.EVT_
>> CACHE_REBALANCE_STARTED"/>
>> 
> >
>  static-field="org.apache.ignite.events.EventType.EVT_
>> CACHE_REBALANCE_PART_LOADED"/>
>> 
> >
>  static-field="org.apache.ignite.events.EventType.EVT_
>> CACHE_REBALANCE_STOPPED"/>
>> 
> >
>  static-field="org.apache.ignite.events.EventType.EVT_
>> CACHE_REBALANCE_PART_UNLOADED"/>
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Port Assigned? Work on specific Node?

[monstereo]

thanks for your understanding,
Last question,
I want to use data rebalancing, because I have scenario like this:

let's say node 1 has 1 datas in its caches. (Which cache mode is
REPLICATED)
Now I will invoke another node2, then node2 will copy of node1's cache
datas.
But when copying occuring, if any client node wants to get data from cache
via node2, I should say "cache is not ready" or node2 should be accessible
after it has all datas.

I though that I can use data rebalancing, that's why i am interested in
events. But, a few minutes ago, I have noticed I can not get
CacheRebalanceEVENT, because of replicated mode. (I can catch other events
for example EVT_CACHE_OBJECT_PUT.

Now what can i do?

here is the cache events in xml file












--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Port Assigned? Work on specific Node?

[monstereo]

thanks,
I am looking for some features about ignite for my case  and I am stuck with
this code:
Event Example Github Ignite

  

In this example works fine, but why ignite node is stopped even if started
in main?

And what is the equivalent of this code without using "->" this

 IgnitePredicate lsnr = evt -> {
System.out.println("Received task event [evt=" + evt.name() + ",
taskName=" + evt.taskName() + ']');

return true; // Return true to continue listening.
};

// Register event listener for all local task execution events.
ignite.events().localListen(lsnr, EVTS_TASK_EXECUTION);




--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Port Assigned? Work on specific Node?

[monstereo]

thanks,
Q2) What is the difference between setClientMode(true) and thin client? I
probably will embed the nodes(which is responsible for CRUD operation for
users). Which one I should, thin client or client Node



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Port Assigned? Work on specific Node?

[monstereo]

I have many question:

- In local we have this line in config file: 

*bean
class="org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder">127.0.0.1:47500..47509*

If I understood properly, our node sends a broadcast to message to other
nodes which have address 127.0.0.1 and port numbers range is 47500-47509,
and those other nodes send their ip address to our nodes.

*Q1) I have question about port number. Why port range is 47500-47509? We
can determine specific port number to specific node?*

*Q2) Let's say I have 2 nodes, node 1 is holding all cache data, and node 2
is holding also all cache data (REPLICATED), then I am creating clientNode3
(which will be client), and I want clientNode3 to operate (insert,delete
...) just on node2, and if there is an update on node2 caches, it will
delegate to node1 to uptade.(therefore database underlying these nodes will
be updated). Can I work on just one node?*



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Hibernate L2 cache with Ignite. How?

[monstereo]

Finally I can run the codes, and I am getting cache hits, puts or miss.

But I want to iterate all the cache, and want to see how many elements in
it.

(I could not see any configuration about cache key,value in the
ignite-configuration.xml) 
(Actually its size always showing 0) 
In ignite configuration.xml:











Here is the code that I have written:

public static void printCache(Ignite ignite){
IgniteCache igniteCache = ignite.getOrCreateCache("Person");
Iterator itr = igniteCache.iterator();
System.out.println("asdaas");
while (itr.hasNext()){
System.out.println(itr.next().getKey() + " " +
itr.next().getValue());
}
}





ezhuravlev wrote
> Why can't you add the dependency from the 3rd party repository, that was
> described on the page I've shared earlier?
> 
> Evgenii
> 
> 2018-07-12 16:22 GMT+03:00 monstereo 

> mehmetozanguven@

> :
> 
>> I know, it is hard to answer, but I don't know what exactly I should
>> do...
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Hibernate L2 cache with Ignite. How?

[monstereo]

I couldn't find it...

ezhuravlev wrote
> Why can't you add the dependency from the 3rd party repository, that was
> described on the page I've shared earlier?
> 
> Evgenii
> 
> 2018-07-12 16:22 GMT+03:00 monstereo 

> mehmetozanguven@

> :
> 
>> I know, it is hard to answer, but I don't know what exactly I should
>> do...
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Hibernate L2 cache with Ignite. How?

[monstereo]

I know, it is hard to answer, but I don't know what exactly I should do... 



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Hibernate L2 cache with Ignite. How?

[monstereo]

?


ezhuravlev wrote
> I've added maven dependency as was described before and this problem was
> resolved.
> 
> Evgenii
> 
> 2018-07-12 15:25 GMT+03:00 monstereo 

> mehmetozanguven@

> :
> 
>> I can not solve this error :
>>
>> *Exception in thread "main" org.hibernate.service.spi.ServiceException:
>> Unable to create requested service
>> [org.hibernate.cache.spi.RegionFactory]
>>
>> at
>> org.hibernate.service.internal.AbstractServiceRegistryImpl.createService(
>> AbstractServiceRegistryImpl.java:244)
>> at
>> org.hibernate.service.internal.AbstractServiceRegistryImpl.
>> initializeService(AbstractServiceRegistryImpl.java:208)
>> at
>> org.hibernate.service.internal.AbstractServiceRegistryImpl.getService(
>> AbstractServiceRegistryImpl.java:189)
>> at
>> org.hibernate.boot.internal.MetadataBuilderImpl$
>> MetadataBuildingOptionsImpl.
> 
> (MetadataBuilderImpl.java:663)
>> at
>> org.hibernate.boot.internal.MetadataBuilderImpl.
> 
> (MetadataBuilderImpl.java:127)
>>
>> at
>> org.hibernate.boot.internal.MetadataBuilderImpl.
> 
> (MetadataBuilderImpl.java:94)
>>
>> at
>> org.hibernate.boot.MetadataSources.getMetadataBuilder(MetadataSources.java:125)
>>
>> at
>> org.hibernate.boot.MetadataSources.buildMetadata(MetadataSources.java:179)
>>
>> at MainApp.createHibernateSessionFactory(MainApp.java:31)   at
>> MainApp.main(MainApp.java:65) Caused by:
>> org.hibernate.HibernateException:
>> could not instantiate RegionFactory
>> [org.apache.ignite.cache.hibernate.HibernateRegionFactory]  at
>> org.hibernate.cache.internal.RegionFactoryInitiator.initiateService(
>> RegionFactoryInitiator.java:84)
>> at
>> org.hibernate.cache.internal.RegionFactoryInitiator.initiateService(
>> RegionFactoryInitiator.java:29)
>> at
>> org.hibernate.boot.registry.internal.StandardServiceRegistryImpl.
>> initiateService(StandardServiceRegistryImpl.java:88)
>> at
>> org.hibernate.service.internal.AbstractServiceRegistryImpl.createService(
>> AbstractServiceRegistryImpl.java:234)
>> ... 9 more Caused by:
>> org.hibernate.boot.registry.selector.spi.StrategySelectionException:
>> Unable
>> to resolve name
>> [org.apache.ignite.cache.hibernate.HibernateRegionFactory]
>> as strategy [org.hibernate.cache.spi.RegionFactory] at
>> org.hibernate.boot.registry.selector.internal.StrategySelectorImpl.
>> selectStrategyImplementor(StrategySelectorImpl.java:113)
>> at
>> org.hibernate.cache.internal.RegionFactoryInitiator.initiateService(
>> RegionFactoryInitiator.java:71)
>> ... 12 more*
>>
>>
>> I have a database (postgres) which has Person table in testdb database,
>> and
>> includes id, name, age, salary columns
>>
>> Here is the my hibernate config file :  hibernate-cfg.xml
>> http://apache-ignite-users.70518.x6.nabble.com/file/
>  t1901/hibernate-cfg.xml>
>>
>> Here is the Person class  :  Person.java
>> http://apache-ignite-users.70518.x6.nabble.com/file/t1901/Person.java;
>>
>> Here is the ignite configuration:  ignite-configuration.xml
>> http://apache-ignite-users.70518.x6.nabble.com/file/
>  t1901/ignite-configuration.xml>
>>
>> Here is the IgniteFactory class(I have created) :  IgniteFactory.java
>> http://apache-ignite-users.70518.x6.nabble.com/file/
>  t1901/IgniteFactory.java>
>>
>> Finally main class :  MainApp.java
>> http://apache-ignite-users.70518.x6.nabble.com/file/t1901/MainApp.java;
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Hibernate L2 cache with Ignite. How?

[monstereo]

I can not solve this error : 

*Exception in thread "main" org.hibernate.service.spi.ServiceException:
Unable to create requested service [org.hibernate.cache.spi.RegionFactory] 
at
org.hibernate.service.internal.AbstractServiceRegistryImpl.createService(AbstractServiceRegistryImpl.java:244)
 
at
org.hibernate.service.internal.AbstractServiceRegistryImpl.initializeService(AbstractServiceRegistryImpl.java:208)
 
at
org.hibernate.service.internal.AbstractServiceRegistryImpl.getService(AbstractServiceRegistryImpl.java:189)
 
at
org.hibernate.boot.internal.MetadataBuilderImpl$MetadataBuildingOptionsImpl.(MetadataBuilderImpl.java:663)
 
at
org.hibernate.boot.internal.MetadataBuilderImpl.(MetadataBuilderImpl.java:127)
 
at
org.hibernate.boot.internal.MetadataBuilderImpl.(MetadataBuilderImpl.java:94)
 
at
org.hibernate.boot.MetadataSources.getMetadataBuilder(MetadataSources.java:125) 
at
org.hibernate.boot.MetadataSources.buildMetadata(MetadataSources.java:179) 
at MainApp.createHibernateSessionFactory(MainApp.java:31)   at
MainApp.main(MainApp.java:65) Caused by: org.hibernate.HibernateException:
could not instantiate RegionFactory
[org.apache.ignite.cache.hibernate.HibernateRegionFactory]  at
org.hibernate.cache.internal.RegionFactoryInitiator.initiateService(RegionFactoryInitiator.java:84)
 
at
org.hibernate.cache.internal.RegionFactoryInitiator.initiateService(RegionFactoryInitiator.java:29)
 
at
org.hibernate.boot.registry.internal.StandardServiceRegistryImpl.initiateService(StandardServiceRegistryImpl.java:88)
 
at
org.hibernate.service.internal.AbstractServiceRegistryImpl.createService(AbstractServiceRegistryImpl.java:234)
 
... 9 more Caused by:
org.hibernate.boot.registry.selector.spi.StrategySelectionException: Unable
to resolve name [org.apache.ignite.cache.hibernate.HibernateRegionFactory]
as strategy [org.hibernate.cache.spi.RegionFactory] at
org.hibernate.boot.registry.selector.internal.StrategySelectorImpl.selectStrategyImplementor(StrategySelectorImpl.java:113)
 
at
org.hibernate.cache.internal.RegionFactoryInitiator.initiateService(RegionFactoryInitiator.java:71)
 
... 12 more*


I have a database (postgres) which has Person table in testdb database, and
includes id, name, age, salary columns

Here is the my hibernate config file :  hibernate-cfg.xml
  

Here is the Person class  :  Person.java
  

Here is the ignite configuration:  ignite-configuration.xml

  

Here is the IgniteFactory class(I have created) :  IgniteFactory.java
  

Finally main class :  MainApp.java
  



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Hibernate L2 cache with ignite

[monstereo]

Give me this error all the time


Exception in thread "main" org.hibernate.service.spi.ServiceException: 
Unable to create requested service [org.hibernate.cache.spi.RegionFactory] 

Unable to resolve name 
[org.apache.ignite.cache.hibernate.HibernateRegionFactory] as strategy 
[org.hibernate.cache.spi.RegionFactory] 


ezhuravlev wrote
> What do you mean by "I couldn't handle this cache"? Sorry, I didn't get
> it.
> 
> What is the problem that you have now?
> 
> Evgenii
> 
> 2018-07-11 12:58 GMT+03:00 

> mehmetozanguven@

> :
> 
>> Thank you for you understanding,
>> Hovewer, I could not handle this cache, even I code is simple
>>
>> If i can share my java file, can you look at it? I have to understand
>> hibernate cache l2
>>
>> And could you give me the fully path of the jar files, and depedencies
>> that I need.
>>
>> Here is the zip file:
>>
>> https://drive.google.com/open?id=1CCmWa_fTMkgs4x2wgmc2YrCeDn1nVi6y
>>
>>
>> Thank you.
>>
>> _
>> Sent from http://apache-ignite-users.70518.x6.nabble.com
>>
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Hibernate L2 cache with Ignite. How?

[monstereo]

anyone could help me?



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Hibernate L2 cache with Ignite. How?

[monstereo]

Ignite github address says that "Required libs will appear at
/target/release-package/libs/optional subfolders."

When I go to that library, I can not see ignite-hibernate or something like
that.
Here is the my path:
/Desktop/ApacheIgniteSourceFolder/apache-ignite-2.5.0-src/target/release-package-fabric/libs/optional


ezhuravlev wrote
> Hibernate is LGPL-licensed, so we stopped deploying there. To get
> artifacts
> for 2.5 version that have LGPL dependencies, you need to build them from
> the source [1] and deploy in your local repo.
> 
> [1] http://ignite.apache.org/download.cgi#build-source
> 
> 2018-07-10 21:46 GMT+03:00 monstereo 

> mehmetozanguven@

> :
> 
>> I have create what apache ignite is said, but i got this exception:
>>
>> Exception in thread "main" org.hibernate.service.spi.ServiceException:
>> Unable to create requested service
>> [org.hibernate.cache.spi.RegionFactory]
>>
>> Unable to resolve name
>> [org.apache.ignite.cache.hibernate.HibernateRegionFactory] as strategy
>> [org.hibernate.cache.spi.RegionFactory]
>>
>>
>>
>> here is the dependencies that i am using:
>>
>> 
> 
>> 
> 
>> 
> 
> org.apache.ignite
> 
>> 
> 
> ignite-hibernate
> 
>> 
> 
> 1.2.0-incubating
> 
>> 
> 
>> 
> 
>> 
> 
> org.apache.ignite
> 
>> 
> 
> ignite-core
> 
>> 
> 
> 2.5.0
> 
>> 
> 
>> 
> 
>> 
> 
> org.apache.ignite
> 
>> 
> 
> ignite-spring
> 
>> 
> 
> 2.5.0
> 
>> 
> 
>> 
> 
>> 
> 
> postgresql
> 
>> 
> 
> postgresql
> 
>> 
> 
> 9.1-901-1.jdbc4
> 
>> 
> 
>>
>> 
> 
>> 
> 
> org.apache.ignite
> 
>> 
> 
> ignite-examples
> 
>> 
> 
> 1.0.0-RC3
> 
>> 
> 
>> 
> 
>> 
> 
> org.hibernate
> 
>> 
> 
> hibernate-core
> 
>> 
> 
> 5.3.2.Final
> 
>> 
> 
>> 
> 
>> 
> 
> org.hibernate
> 
>> 
> 
> hibernate-annotations
> 
>> 
> 
> 3.5.6-Final
> 
>> 
> 
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Hibernate L2 cache with Ignite. How?

[monstereo]

I'm confused how to use these jar. I have the run the command "$ mvn clean
package -DskipTests -Prelease,lgpl"

and many things have been done successfully ignite-aws,
ignite-hibernate-core vs

now how i am going to use them:

I have added them directly but given me the same error, here is the
dependencies 


org.apache.ignite
ignite-core
2.5.0


org.apache.ignite
ignite-spring
2.5.0




org.apache.ignite
ignite-hibernate-core
2.5.0




postgresql
postgresql
9.1-901-1.jdbc4


org.apache.ignite
ignite-examples
2.5.0


org.hibernate
hibernate-core
5.3.2.Final


org.hibernate
hibernate-annotations
3.5.6-Final







ezhuravlev wrote
> Hibernate is LGPL-licensed, so we stopped deploying there. To get
> artifacts
> for 2.5 version that have LGPL dependencies, you need to build them from
> the source [1] and deploy in your local repo.
> 
> [1] http://ignite.apache.org/download.cgi#build-source
> 
> 2018-07-10 21:46 GMT+03:00 monstereo 

> mehmetozanguven@

> :
> 
>> I have create what apache ignite is said, but i got this exception:
>>
>> Exception in thread "main" org.hibernate.service.spi.ServiceException:
>> Unable to create requested service
>> [org.hibernate.cache.spi.RegionFactory]
>>
>> Unable to resolve name
>> [org.apache.ignite.cache.hibernate.HibernateRegionFactory] as strategy
>> [org.hibernate.cache.spi.RegionFactory]
>>
>>
>>
>> here is the dependencies that i am using:
>>
>> 
> 
>> 
> 
>> 
> 
> org.apache.ignite
> 
>> 
> 
> ignite-hibernate
> 
>> 
> 
> 1.2.0-incubating
> 
>> 
> 
>> 
> 
>> 
> 
> org.apache.ignite
> 
>> 
> 
> ignite-core
> 
>> 
> 
> 2.5.0
> 
>> 
> 
>> 
> 
>> 
> 
> org.apache.ignite
> 
>> 
> 
> ignite-spring
> 
>> 
> 
> 2.5.0
> 
>> 
> 
>> 
> 
>> 
> 
> postgresql
> 
>> 
> 
> postgresql
> 
>> 
> 
> 9.1-901-1.jdbc4
> 
>> 
> 
>>
>> 
> 
>> 
> 
> org.apache.ignite
> 
>> 
> 
> ignite-examples
> 
>> 
> 
> 1.0.0-RC3
> 
>> 
> 
>> 
> 
>> 
> 
> org.hibernate
> 
>> 
> 
> hibernate-core
> 
>> 
> 
> 5.3.2.Final
> 
>> 
> 
>> 
> 
>> 
> 
> org.hibernate
> 
>> 
> 
> hibernate-annotations
> 
>> 
> 
> 3.5.6-Final
> 
>> 
> 
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Hibernate L2 cache with Ignite. How?

[monstereo]

I have create what apache ignite is said, but i got this exception:

Exception in thread "main" org.hibernate.service.spi.ServiceException:
Unable to create requested service [org.hibernate.cache.spi.RegionFactory]

Unable to resolve name
[org.apache.ignite.cache.hibernate.HibernateRegionFactory] as strategy
[org.hibernate.cache.spi.RegionFactory]



here is the dependencies that i am using:



org.apache.ignite
ignite-hibernate
1.2.0-incubating


org.apache.ignite
ignite-core
2.5.0


org.apache.ignite
ignite-spring
2.5.0


postgresql
postgresql
9.1-901-1.jdbc4



org.apache.ignite
ignite-examples
1.0.0-RC3


org.hibernate
hibernate-core
5.3.2.Final


org.hibernate
hibernate-annotations
3.5.6-Final




--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Hibernate L2 cache with Ignite. How?

[monstereo]

thanks,
then in hibernate l2 cache, we do not provide the specific data to load
cache?(igniteCache.loadCache() )
but then, how many data will be in l2 cache, can I limit this space?


ilya.kasnacheev wrote
> Hello!
> 
> From the comments of Java file linked:
> 
> * When running example, it's easy to notice that when an object is first
> * put into a database, the L2 cache is not used and it's contents is
> empty.
> * However, *when an object is first read from the database, it is
> immediately*
> * *stored in L2 cache (which is Ignite In-Memory Data Ignite cluster in
> fact)*, which can
> * be seen in stats output. Further requests of the same object only read
> the data
> * from L2 cache and do not hit the database.
> 
> Regards,
> 
> -- 
> Ilya Kasnacheev
> 
> 2018-07-10 16:23 GMT+03:00 monstereo 

> mehmetozanguven@

> :
> 
>> Thanks.
>> I have seen this document before.
>> However, I could not understand how datas are loading ignite cache(s)?
>> Can you explain what is going on this .java class?
>>
>>
>>
>> ezhuravlev wrote
>> > Looks like you read a wrong documentation, for Hibernate L2 cache you
>> > don't
>> > even need to implement CacheStoreAdapter - it's needed only for using
>> 3rd
>> > party db as a Cache Store. Here is the right documentation for using
>> > Ignite
>> > as L2 Hibernate cache:
>> > https://apacheignite-mix.readme.io/docs/hibernate-l2-cache
>> >
>> > Also, here is the working example:
>> > https://github.com/apache/ignite/blob/master/examples/
>> src/main/java-lgpl/org/apache/ignite/examples/datagrid/hibernate/
>> HibernateL2CacheExample.java
>> >
>> > Evgenii
>> >
>> > 2018-07-10 15:59 GMT+03:00 monstereo 
>>
>> > mehmetozanguven@
>>
>> > :
>> >
>> >> Even I am using apache ignite documentation or High Performance
>> In-Memory
>> >> computing book,
>> >> I could not understand.
>> >>
>> >> I have created simple cache with ignite (using postgresql)
>> (implementing
>> >> CacheStoreAdapter vs...)
>> >> Also I have created simple hibernate project (gets data from database,
>> >> update vs...)
>> >>
>> >> But I can not combine them.
>> >>
>> >> *Could someone explain the job step by step ?*
>> >> (In High Performance In-Memory computing book -> all xml configuration
>> in
>> >> a
>> >> file which I could not handle at all, if possible, I want to create
>> all
>> >> the
>> >> xml file seperately)
>> >>
>> >> thanks,
>> >>
>> >>
>> >>
>> >>
>> >> --
>> >> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>> >>
>>
>>
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Hibernate L2 cache with Ignite. How?

[monstereo]

Thanks.
I have seen this document before.
However, I could not understand how datas are loading ignite cache(s)?
Can you explain what is going on this .java class?



ezhuravlev wrote
> Looks like you read a wrong documentation, for Hibernate L2 cache you
> don't
> even need to implement CacheStoreAdapter - it's needed only for using 3rd
> party db as a Cache Store. Here is the right documentation for using
> Ignite
> as L2 Hibernate cache:
> https://apacheignite-mix.readme.io/docs/hibernate-l2-cache
> 
> Also, here is the working example:
> https://github.com/apache/ignite/blob/master/examples/src/main/java-lgpl/org/apache/ignite/examples/datagrid/hibernate/HibernateL2CacheExample.java
> 
> Evgenii
> 
> 2018-07-10 15:59 GMT+03:00 monstereo 

> mehmetozanguven@

> :
> 
>> Even I am using apache ignite documentation or High Performance In-Memory
>> computing book,
>> I could not understand.
>>
>> I have created simple cache with ignite (using postgresql) (implementing
>> CacheStoreAdapter vs...)
>> Also I have created simple hibernate project (gets data from database,
>> update vs...)
>>
>> But I can not combine them.
>>
>> *Could someone explain the job step by step ?*
>> (In High Performance In-Memory computing book -> all xml configuration in
>> a
>> file which I could not handle at all, if possible, I want to create all
>> the
>> xml file seperately)
>>
>> thanks,
>>
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Hibernate L2 cache with Ignite. How?

[monstereo]

Even I am using apache ignite documentation or High Performance In-Memory
computing book,
I could not understand.

I have created simple cache with ignite (using postgresql) (implementing
CacheStoreAdapter vs...)
Also I have created simple hibernate project (gets data from database,
update vs...)

But I can not combine them.

*Could someone explain the job step by step ?*
(In High Performance In-Memory computing book -> all xml configuration in a
file which I could not handle at all, if possible, I want to create all the
xml file seperately)

thanks,




--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Apache Ignite with Caching : How do I sure that cache(s) has all datas?

[monstereo]

then may ask you what is difference between 
https://apacheignite.readme.io/docs/primary-and-backup-copies#section-synchronous-and-asynchronous-backups
this and rebalance mode

thanks,


slava.koptilin wrote
> Hello,
> 
> I think rebalancing makes sense for all types of caches. It does not
> matter
> what type of cache you use.
> Long story short, a replicated cache is a partitioned cache with the
> number
> of backups equals to the number of nodes minus 1.
> 
> Let's assume that you ingested all data in the cluster, and after that,
> added a new node.
> In that case, data will be transferred/copied to a new node during
> rebalancing.
> 
> Perhaps, EVT_CACHE_REBALANCE_STARTED and EVT_CACHE_REBALANCE_STOPPED will
> be useful to track rebalancing.
> 
> Thanks,
> Slava.
> 
> вс, 8 июл. 2018 г. в 15:47, Amir Akhmedov 

> amir.akhmedov@

> :
> 
>> Rebalancing is a process when a node joins or leaves (in case backup is
>> turned on) a cluster, data will be rebalanced within a cluster to make a
>> fair distribution. It's applicable only for partitioned caches. But you
>> have replicated cache and it's out of your case.
>>
>> Thanks,
>> Amir
>>
>> On Jul 8, 2018 4:02 AM, "monstereo" 

> mehmetozanguven@

>  wrote:
>>
>> thank you for your comment,
>> I also found that there is a data rebalance in ignite.
>> What do you think about this? Which one should I use?
>>
>> Here is the data rebalance link  here
>> https://apacheignite.readme.io/docs/rebalancing;
>>
>> For SYNCH mode in rebalance says that :::
>>
>> "Synchronous rebalancing mode. Distributed caches will not start until
>> all
>> necessary data is loaded from other available grid nodes. This means that
>> any call to cache public API will be blocked until rebalancing is
>> finished."
>>
>>
>>
>>
>>
>>
>> --
>> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>>
>>
>>





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Apache Ignite with Caching : How do I sure that cache(s) has all datas?

[monstereo]

I haven't noticed that. 
thank you,
Amir Akhmedov wrote
> Rebalancing is a process when a node joins or leaves (in case backup is
> turned on) a cluster, data will be rebalanced within a cluster to make a
> fair distribution. It's applicable only for partitioned caches. But you
> have replicated cache and it's out of your case.
> 
> Thanks,
> Amir
> 
> On Jul 8, 2018 4:02 AM, "monstereo" 

> mehmetozanguven@

>  wrote:
> 
> thank you for your comment,
> I also found that there is a data rebalance in ignite.
> What do you think about this? Which one should I use?
> 
> Here is the data rebalance link  here
> https://apacheignite.readme.io/docs/rebalancing;
> 
> For SYNCH mode in rebalance says that :::
> 
> "Synchronous rebalancing mode. Distributed caches will not start until all
> necessary data is loaded from other available grid nodes. This means that
> any call to cache public API will be blocked until rebalancing is
> finished."
> 
> 
> 
> 
> 
> 
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Apache Ignite with Caching : How do I sure that cache(s) has all datas?

[monstereo]

thank you for your comment,
I also found that there is a data rebalance in ignite.
What do you think about this? Which one should I use?

Here is the data rebalance link  here
  

For SYNCH mode in rebalance says that :::

"Synchronous rebalancing mode. Distributed caches will not start until all
necessary data is loaded from other available grid nodes. This means that
any call to cache public API will be blocked until rebalancing is finished."





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Apache Ignite with Caching : How do I sure that cache(s) has all datas?

[monstereo]

Is there any one who can answer my question?



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Apache Ignite with Caching : How do I sure that cache(s) has all datas?

[monstereo]

I'm looking for an answer this question.
Here is the scenario

- I have datas from the database  over 100.000
- I have created cache node(node1) then, I have loaded  100.000 datas to the
cache memory.(REPLICATED mode)
- Now I will create another node(s) which is/are served for client to
consume these datas. However first I have to be sure that all datas from
node1 fully copy in node2(node2, node3... )
- Question how can be sure that all datas are also in node2

- I have seen some people says that "use countlatchdown".



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/