Hi,
Thank you for reply.Thanks to your suggestions i managed to configure good
ignite. All Work but I found another issue... The computation is 20 or 30
times slower than the same computation without put word in cache, maybe 40.
>From what can depend?
This is the Server Code
public static void main(String args[]) throws Exception {
Ignition.setClientMode(false);
try(Ignite ignite =
Ignition.start("/home/hduser/apache-ignite-2.0.0-src/examples/config/example-cache1.xml")){
//CacheConfiguration<String ,Integer> cfg2 = new CacheConfiguration<>();
CacheConfiguration<String,Integer> cfg2=
Ignition.loadSpringBean("/home/hduser/apache-ignite-2.0.0-src/examples/config/example-cache1.xml",
"cacheconf");
IgniteCache<String, Integer> cache;
cache = ignite.getOrCreateCache(cfg2);
//cache.put("uno", 1);
//cache.put("due", 2);
//System.out.println(cache.get("uno"));
//System.out.println(cache.get("due"));
while(true){
}
}
}
This is the WordCount code
public class WordCountIgnite extends Configured implements Tool {
public static void main(String args[]) throws Exception {
int res = ToolRunner.run(new WordCountIgnite(), args);
System.exit(res);
}
public int run(String[] args) throws Exception {
Path inputPath = new Path(args[0]);
Path outputPath = new Path(args[1]);
Configuration conf = getConf();
Job job = Job.getInstance(conf, "word count");
FileInputFormat.setInputPaths(job, inputPath);
FileOutputFormat.setOutputPath(job, outputPath);
job.setJarByClass(this.getClass());
job.setInputFormatClass(TextInputFormat.class);
job.setOutputFormatClass(TextOutputFormat.class);
job.setMapOutputKeyClass(Text.class);
job.setMapOutputValueClass(IntWritable.class);
job.setOutputKeyClass(Text.class);
job.setOutputValueClass(IntWritable.class);
job.setMapperClass(Map.class);
job.setCombinerClass(Reduce.class);
job.setReducerClass(Reduce.class);
return job.waitForCompletion(true) ? 0 : 1;
}
public static class Map extends Mapper<LongWritable, Text, Text,
IntWritable> {
private final static IntWritable one = new IntWritable(1);
private Text word = new Text();
Ignite ignite;
IgniteCache<String, Integer> cache;
@Override protected void setup(Context context) throws IOException,
InterruptedException {
super.setup(context);
ignite =
Ignition.start("/home/hduser/apache-ignite-2.0.0-src/examples/config/example-cache2.xml");
//CacheConfiguration<String ,Integer> cfg2 = new CacheConfiguration<>();
CacheConfiguration<String,Integer> cfg2=
Ignition.loadSpringBean("/home/hduser/apache-ignite-2.0.0-src/examples/config/example-cache1.xml",
"cacheconf");
cache = ignite.getOrCreateCache(cfg2);
//cache.put("test", 1993);
}
@Override
public void map(LongWritable key, Text value, Context context) throws
IOException, InterruptedException {
// String line = value.toString();
// StringTokenizer tokenizer = new StringTokenizer(line);
// while (tokenizer.hasMoreTokens()) {
// word.set(tokenizer.nextToken());
// context.write(word, one);
// }
String[] lines = tokenize(value.toString());
try (IgniteDataStreamer<String, Integer> stmr =
ignite.dataStreamer("Cache")) {
// Stream entries.
for(String token : lines){
//word.set(token);
//context.write(word, one);
stmr.addData(token, 1);
}
}
//cache.put("interno", 666);
}
@Override protected void cleanup(Context context) throws IOException,
InterruptedException {
super.setup(context);
ignite.close();
}
private String[] tokenize(String text) {
text = text.toLowerCase();
text = text.replace("'","");
text = text.replaceAll("[\\s\\W]+", " ").trim();
return text.split(" ");
}
}
public static class Reduce extends Reducer<Text, IntWritable, Text,
IntWritable> {
@Override
public void reduce(Text key, Iterable<IntWritable> values, Context context)
throws IOException, InterruptedException {
int sum = 0;
for (IntWritable value : values) {
sum += value.get();
}
context.write(key, new IntWritable(sum));
}
}
}
This is the Ignite Configuration
<beans xmlns="http://www.springframework.org/schema/beans";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd";>
<bean id="ignite.cfg"
class="org.apache.ignite.configuration.IgniteConfiguration">
<!-- Explicitly configure TCP discovery SPI to provide list of
initial nodes. -->
<property name="discoverySpi">
<bean
class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
<property name="ipFinder">
<!--
Ignite provides several options for automatic
discovery that can be used
instead os static IP based discovery. For
information on all options refer
to our documentation:
http://apacheignite.readme.io/docs/cluster-config
-->
<!-- Uncomment static IP finder to enable static-based
discovery of initial nodes. -->
<!--<bean
class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">-->
<bean
class="org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder">
<property name="addresses">
<list>
<!-- In distributed environment, replace
with actual host IP address. -->
<value>127.0.0.1:47500..47509</value>
<value>192.168.30.5:47500..47509</value>
<value>192.168.30.22:47500..47509</value>
<value>192.168.30.99:47500..47509</value>
</list>
</property>
</bean>
</property>
</bean>
</property>
</bean>
<bean id="cacheconf"
class="org.apache.ignite.configuration.CacheConfiguration">
<property name="name" value="default"/>
<property name="atomicityMode" value="ATOMIC"/>
<property name="backups" value="0"/>
<property name="cacheMode" value="PARTITIONED"/>
<!-- <property name="startSize" value="10"/> -->
</bean>
</beans>
According to Ignite Documentation
https://apacheignite.readme.io/docs/performance-tips I think maybe is a
problem of cache start dimension but i can't set it. I'm using Ignite 2.0.
When I add <property name="startSize" value="10"/> in configuration it
launch exception
Caused by: org.springframework.beans.NotWritablePropertyException: Invalid
property 'startSize' of bean class
[org.apache.ignite.configuration.CacheConfiguration]: Bean property
'startSize' is not writable or has an invalid setter method. Does the
parameter type of the setter match the return type of the getter?
I don't know why.... I tried with cache.put() method but it is slower. Are
they normale this computation times?
I think the times should be similar to those of a normal hadoop
computation. The test are made by 2 slave who are Ignite server Node too,
in Hadoop computation create 2 Client node in there same slave who put data
in cache.
Thanks
Mimmo
2017-06-23 19:28 GMT+02:00 Michael Cherkasov <[email protected]>:
> Hi Mimmo,
>
> The map works in other process, so map creates a new instance of ignite,
> also it doesn't know
> about Ignition.setClientMode(true); that you setup in main method.
> Also you shouldn't create ignite in map method, use Mapper#setup instead:
>
> @Override protected void setup(Context context) throws IOException,
> InterruptedException {
> super.setup(context);
>
> Ignition.setClientMode(true);
>
> TcpDiscoverySpi spi = new TcpDiscoverySpi();
> TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder();
> CacheConfiguration<String ,Integer> cfg2 = new
> CacheConfiguration<>();
> ipFinder.setAddresses(Arrays.asList(put here your ips));
>
> spi.setIpFinder(ipFinder);
>
> IgniteConfiguration cfg = new IgniteConfiguration();
>
> cfg.setDiscoverySpi(spi);
>
> cfg2.setName("demoCache");
> cfg2.setAtomicityMode(CacheAtomicityMode.TRANSACTIONAL);
>
> ignite = Ignition.getOrStart(cfg);
>
> cache = ignite.getOrCreateCache(cfg2);
> }
>
> Also could you please explain why you think that second call of cache.put
> doesn't work?
>
> Thanks,
> Mikhail.
>
>
> 2017-06-23 16:40 GMT+03:00 Mimmo Celano <[email protected]>:
>
>> Hi,
>> Thanks for reply. There's a problem with cache creation.... i resolved
>> starting cache from one of the server node. Now I have another problem,
>> when i run hadoop with there jar file all work, but when i try to put a
>> word in a cache it doesn't put it... I think there's a problem when try to
>> find an Ignite Node running on a slave
>>
>>
>>
>> public class WordCountIgnite extends Configured implements Tool {
>>
>> static IgniteCache<String, Integer> cache;
>> public static void main(String args[]) throws Exception {
>> TcpDiscoverySpi spi = new TcpDiscoverySpi();
>>
>> TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder();
>>
>> // Set initial IP addresses.
>> // Note that you can optionally specify a port or a port range.
>> ipFinder.setAddresses(Arrays.asList("192.168.30.99", "192.168.30.22"));
>>
>> spi.setIpFinder(ipFinder);
>>
>> IgniteConfiguration cfg = new IgniteConfiguration();
>>
>> // Override default discovery SPI.
>> cfg.setDiscoverySpi(spi);
>> // Start Ignite node.
>> Ignition.setClientMode(true);
>> try(Ignite ignite = Ignition.start(cfg)){
>> CacheConfiguration<String ,Integer> cfg2 = new CacheConfiguration<>();
>> cfg2.setName("demoCache");
>> cfg2.setAtomicityMode(CacheAtomicityMode.TRANSACTIONAL);
>> cache = ignite.getOrCreateCache(cfg2);
>> System.out.println(cache.get("anno"));
>>
>> System.out.println(cache.get("mese"));
>> cache.put("test1", 111);
>> int res = ToolRunner.run(new WordCountIgnite(), args);
>> System.exit(res);
>> }
>> }
>>
>> public int run(String[] args) throws Exception {
>> Path inputPath = new Path(args[0]);
>> Path outputPath = new Path(args[1]);
>>
>> Configuration conf = getConf();
>> Job job = Job.getInstance(conf, "word count");
>>
>> FileInputFormat.setInputPaths(job, inputPath);
>> FileOutputFormat.setOutputPath(job, outputPath);
>>
>> job.setJarByClass(this.getClass());
>> job.setInputFormatClass(TextInputFormat.class);
>> job.setOutputFormatClass(TextOutputFormat.class);
>> job.setMapOutputKeyClass(Text.class);
>> job.setMapOutputValueClass(IntWritable.class);
>> job.setOutputKeyClass(Text.class);
>> job.setOutputValueClass(IntWritable.class);
>>
>> job.setMapperClass(Map.class);
>> job.setCombinerClass(Reduce.class);
>> job.setReducerClass(Reduce.class);
>> return job.waitForCompletion(true) ? 0 : 1;
>> }
>>
>> public static class Map extends Mapper<LongWritable, Text, Text,
>> IntWritable> {
>> private final static IntWritable one = new IntWritable(1);
>> private Text word = new Text();
>> @Override
>> public void map(LongWritable key, Text value, Context context) throws
>> IOException, InterruptedException {
>> // String line = value.toString();
>> // StringTokenizer tokenizer = new StringTokenizer(line);
>> // while (tokenizer.hasMoreTokens()) {
>> // word.set(tokenizer.nextToken());
>> // context.write(word, one);
>> // }
>> //CacheConfiguration<String ,Integer> cfg2 = new CacheConfiguration<>();
>> TcpDiscoverySpi spi = new TcpDiscoverySpi();
>>
>> TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder();
>> CacheConfiguration<String ,Integer> cfg2 = new CacheConfiguration<>();
>> // Set initial IP addresses.
>> // Note that you can optionally specify a port or a port range.
>> ipFinder.setAddresses(Arrays.asList("192.168.30.99", "192.168.30.22"));
>>
>> spi.setIpFinder(ipFinder);
>>
>> IgniteConfiguration cfg = new IgniteConfiguration();
>>
>> // Override default discovery SPI.
>> cfg.setDiscoverySpi(spi);
>> cfg2.setName("demoCache");
>> cfg2.setAtomicityMode(CacheAtomicityMode.TRANSACTIONAL);
>> try{
>> Ignite ignite = Ignition.getOrStart(cfg); ------>MAYBE THERE IT'S
>> PROBLEM
>> cache = ignite.getOrCreateCache(cfg2);
>> }catch(Exception e){
>> System.out.println("xception");
>> }
>> cache.put("test", 123); ----->NOT WORK
>> //System.out.println(cache.get("anno"));
>>
>> //System.out.println(cache.get("mese"));
>> String[] lines = tokenize(value.toString());
>> for(String token : lines){
>> word.set(token);
>> context.write(word, one);
>> }
>> }
>> private String[] tokenize(String text) {
>> text = text.toLowerCase();
>> text = text.replace("'","");
>> text = text.replaceAll("[\\s\\W]+", " ").trim();
>> return text.split(" ");
>> }
>> }
>>
>> public static class Reduce extends Reducer<Text, IntWritable, Text,
>> IntWritable> {
>>
>> @Override
>> public void reduce(Text key, Iterable<IntWritable> values, Context
>> context) throws IOException, InterruptedException {
>> int sum = 0;
>> for (IntWritable value : values) {
>> sum += value.get();
>> }
>>
>> context.write(key, new IntWritable(sum));
>> }
>> }
>>
>> }
>>
>>
>> The first put "test1" it'ok, the second no. Maybe can't find the Ignite
>> running on the node.... The Map function in Hadoop where compute by the
>> slave who in wich case are running Ignite. The computation don't crash so i
>> think that it create another Ignite Start and another cache where put all
>> word of a map stage.... Can you Help me?
>>
>> Thanks
>>
>> 2017-06-21 16:32 GMT+02:00 mimmo_c <[email protected]>:
>>
>>> Hi, I'm trying to configure Ignite for hadoop. I would like to store the
>>> data
>>> of a wordcount inside a grid cache between two server node. I'm on a
>>> Cluster
>>> of 33 nodes but i want try with 3 node.
>>> When I start two node in server mode they connect itselfef with ignite.sh
>>> <hadoop/default-configuration.xml>. From the master node I run hadoop
>>> with
>>> the jar of wordcount in wich just start ignite in client mode and try to
>>> start a cache . For configuration i use default-configuration.xml in
>>> config/hadoop.
>>>
>>> When i start hadoop from master it gives this error
>>>
>>>
>>> >>> __________ ________________
>>> >>> / _/ ___/ |/ / _/_ __/ __/
>>> >>> _/ // (7 7 // / / / / _/
>>> >>> /___/\___/_/|_/___/ /_/ /___/
>>> >>>
>>> >>> ver. 2.0.0#20170430-sha1:d4eef3c6
>>> >>> 2017 Copyright(C) Apache Software Foundation
>>> >>>
>>> >>> Ignite documentation: http://ignite.apache.org
>>>
>>> 2017-06-21 13:53:47,737 INFO [main] internal.IgniteKernal
>>> (Log4JLogger.java:info(475)) - Config URL:
>>> file:/home/hduser/apache-ignite-2.0.0-src/config/hadoop/defa
>>> ult-config.xml
>>> 2017-06-21 13:53:47,737 INFO [main] internal.IgniteKernal
>>> (Log4JLogger.java:info(475)) - Daemon mode: off
>>> 2017-06-21 13:53:47,737 INFO [main] internal.IgniteKernal
>>> (Log4JLogger.java:info(475)) - OS: Linux 4.4.0-79-generic amd64
>>> 2017-06-21 13:53:47,737 INFO [main] internal.IgniteKernal
>>> (Log4JLogger.java:info(475)) - OS user: hduser
>>> 2017-06-21 13:53:47,739 INFO [main] internal.IgniteKernal
>>> (Log4JLogger.java:info(475)) - PID: 22611
>>> 2017-06-21 13:53:47,739 INFO [main] internal.IgniteKernal
>>> (Log4JLogger.java:info(475)) - Language runtime: Java Platform API
>>> Specification ver. 1.8
>>> 2017-06-21 13:53:47,739 INFO [main] internal.IgniteKernal
>>> (Log4JLogger.java:info(475)) - VM information: Java(TM) SE Runtime
>>> Environment 1.8.0_131-b11 Oracle Corporation Java HotSpot(TM) 64-Bit
>>> Server
>>> VM 25.131-b11
>>> 2017-06-21 13:53:47,740 INFO [main] internal.IgniteKernal
>>> (Log4JLogger.java:info(475)) - VM total memory: 0.87GB
>>> 2017-06-21 13:53:47,740 INFO [main] internal.IgniteKernal
>>> (Log4JLogger.java:info(475)) - Remote Management [restart: off, REST:
>>> off,
>>> JMX (remote: off)]
>>> 2017-06-21 13:53:47,740 INFO [main] internal.IgniteKernal
>>> (Log4JLogger.java:info(475)) -
>>> IGNITE_HOME=/home/hduser/apache-ignite-2.0.0-src
>>> 2017-06-21 13:53:47,741 INFO [main] internal.IgniteKernal
>>> (Log4JLogger.java:info(475)) - VM arguments: [-Xmx1000m,
>>> -Dhadoop.log.dir=/usr/local/hadoop/logs, -Dhadoop.log.file=hadoop.log,
>>> -Dhadoop.home.dir=/usr/local/hadoop, -Dhadoop.id.str=,
>>> -Dhadoop.root.logger=INFO,console,
>>> -Djava.library.path=/usr/local/hadoop/lib/native,
>>> -Dhadoop.policy.file=hadoop-policy.xml, -Djava.net.preferIPv4Stack=true,
>>> -Dhadoop.security.logger=INFO,NullAppender]
>>> 2017-06-21 13:53:47,741 INFO [main] internal.IgniteKernal
>>> (Log4JLogger.java:info(475)) - Configured caches [in 'default'
>>> memoryPolicy:
>>> ['ignite-sys-cache', 'ignite-hadoop-mr-sys-cache',
>>> 'ignite-atomics-sys-cache', 'igfs-internal-igfs-meta',
>>> 'igfs-internal-igfs-data']]
>>> 2017-06-21 13:53:47,744 INFO [main] internal.IgniteKernal
>>> (Log4JLogger.java:info(475)) - 3-rd party licenses can be found at:
>>> /home/hduser/apache-ignite-2.0.0-src/libs/licenses
>>> 2017-06-21 13:53:47,746 WARN [pub-#14%null%] internal.GridDiagnostic
>>> (Log4JLogger.java:warning(480)) - Initial heap size is 504MB (should be
>>> no
>>> less than 512MB, use -Xms512m -Xmx512m).
>>> 2017-06-21 13:53:47,794 INFO [main] plugin.IgnitePluginProcessor
>>> (Log4JLogger.java:info(475)) - Configured plugins:
>>> 2017-06-21 13:53:47,794 INFO [main] plugin.IgnitePluginProcessor
>>> (Log4JLogger.java:info(475)) - ^-- None
>>> 2017-06-21 13:53:47,794 INFO [main] plugin.IgnitePluginProcessor
>>> (Log4JLogger.java:info(475)) -
>>> 2017-06-21 13:53:47,842 INFO [main] tcp.TcpCommunicationSpi
>>> (Log4JLogger.java:info(475)) - Successfully bound communication NIO
>>> server
>>> to TCP port [port=47100, locHost=0.0.0.0/0.0.0.0, selectorsCnt=4,
>>> selectorSpins=0, pairedConn=false]
>>> 2017-06-21 13:53:47,846 WARN [main] tcp.TcpCommunicationSpi
>>> (Log4JLogger.java:warning(480)) - Message queue limit is set to 0 which
>>> may
>>> lead to potential OOMEs when running cache operations in FULL_ASYNC or
>>> PRIMARY_SYNC modes due to message queues growth on sender and receiver
>>> sides.
>>> 2017-06-21 13:53:47,864 WARN [main] noop.NoopCheckpointSpi
>>> (Log4JLogger.java:warning(480)) - Checkpoints are disabled (to enable
>>> configure any GridCheckpointSpi implementation)
>>> 2017-06-21 13:53:47,889 WARN [main] collision.GridCollisionManager
>>> (Log4JLogger.java:warning(480)) - Collision resolution is disabled (all
>>> jobs
>>> will be activated upon arrival).
>>> 2017-06-21 13:53:47,890 INFO [main] internal.IgniteKernal
>>> (Log4JLogger.java:info(475)) - Security status [authentication=off,
>>> tls/ssl=off]
>>> 2017-06-21 13:53:48,181 INFO [main] rest.GridRestProcessor
>>> (Log4JLogger.java:info(475)) - REST protocols do not start on client
>>> node.
>>> To start the protocols on client node set
>>> '-DIGNITE_REST_START_ON_CLIENT=true' system property.
>>> 2017-06-21 13:53:48,230 INFO [main] loopback.IpcServerTcpEndpoint
>>> (Log4JLogger.java:info(475)) - IPC server loopback endpoint started
>>> [port=10500]
>>> 2017-06-21 13:53:48,232 INFO [main] loopback.IpcServerTcpEndpoint
>>> (Log4JLogger.java:info(475)) - IPC server loopback endpoint started
>>> [port=11400]
>>> 2017-06-21 13:53:48,246 INFO [main] hadoop.HadoopProcessor
>>> (Log4JLogger.java:info(475)) - HADOOP_HOME is set to /usr/local/hadoop
>>> 2017-06-21 13:53:48,246 INFO [main] hadoop.HadoopProcessor
>>> (Log4JLogger.java:info(475)) - Resolved Hadoop classpath locations:
>>> /usr/local/hadoop, /usr/local/hadoop, /usr/local/hadoop
>>> 2017-06-21 13:53:48,248 WARN [main] hadoop.HadoopProcessor
>>> (Log4JLogger.java:warning(480)) - Hadoop libraries are found in Ignite
>>> classpath, this could lead to class loading errors (please remove all
>>> Hadoop
>>> libraries from Ignite classpath)
>>> [path=file:/usr/local/hadoop/share/hadoop/common/hadoop-comm
>>> on-2.7.3.jar]
>>> 2017-06-21 13:53:48,281 INFO [main] internal.IgniteKernal
>>> (Log4JLogger.java:info(475)) - Non-loopback local IPs: 192.168.30.5
>>> 2017-06-21 13:53:48,281 INFO [main] internal.IgniteKernal
>>> (Log4JLogger.java:info(475)) - Enabled local MACs: FA163E27B794
>>> 2017-06-21 13:53:48,394 WARN [main] discovery.GridDiscoveryManager
>>> (Log4JLogger.java:warning(480)) - Local node's value of
>>> 'java.net.preferIPv4Stack' system property differs from remote node's
>>> (all
>>> nodes in topology should have identical value) [locPreferIpV4=true,
>>> rmtPreferIpV4=null, locId8=2df6b461, rmtId8=927af8bb,
>>> rmtAddrs=[slave-1/0:0:0:0:0:0:0:1%lo, /127.0.0.1, /192.168.30.22]]
>>> 2017-06-21 13:53:48,596 INFO [main] cache.GridCacheProcessor
>>> (Log4JLogger.java:info(475)) - Started cache
>>> [name=ignite-hadoop-mr-sys-cache, memoryPolicyName=sysMemPlc,
>>> mode=REPLICATED]
>>> 2017-06-21 13:53:48,607 INFO [main] cache.GridCacheProcessor
>>> (Log4JLogger.java:info(475)) - Started cache [name=ignite-sys-cache,
>>> memoryPolicyName=sysMemPlc, mode=REPLICATED]
>>> 2017-06-21 13:53:48,609 INFO [main] cache.GridCacheProcessor
>>> (Log4JLogger.java:info(475)) - Started cache
>>> [name=ignite-atomics-sys-cache,
>>> memoryPolicyName=sysMemPlc, mode=PARTITIONED]
>>> 2017-06-21 13:53:48,618 INFO [main] cache.GridCacheProcessor
>>> (Log4JLogger.java:info(475)) - Started cache
>>> [name=igfs-internal-igfs-data,
>>> memoryPolicyName=sysMemPlc, mode=PARTITIONED]
>>> 2017-06-21 13:53:48,620 INFO [main] cache.GridCacheProcessor
>>> (Log4JLogger.java:info(475)) - Started cache
>>> [name=igfs-internal-igfs-meta,
>>> memoryPolicyName=sysMemPlc, mode=PARTITIONED]
>>> 2017-06-21 13:53:50,666 WARN [exchange-worker-#25%null%]
>>> dht.GridDhtAssignmentFetchFuture (Log4JLogger.java:warning(480)) -
>>> Failed to
>>> request affinity assignment from remote node (will continue to another
>>> node): TcpDiscoveryNode [id=927af8bb-e105-4332-baf3-072f921d09cd,
>>> addrs=[0:0:0:0:0:0:0:1%lo, 127.0.0.1, 192.168.30.22],
>>> sockAddrs=[0:0:0:0:0:0:0:1%lo:47500, /127.0.0.1:47500,
>>> slave-1/192.168.30.22:47500], discPort=47500, order=1, intOrder=1,
>>> lastExchangeTime=1498053228353, loc=false,
>>> ver=2.0.0#20170430-sha1:d4eef3c6,
>>> isClient=false]
>>> 2017-06-21 13:53:52,686 WARN [exchange-worker-#25%null%]
>>> dht.GridDhtAssignmentFetchFuture (Log4JLogger.java:warning(480)) -
>>> Failed to
>>> request affinity assignment from remote node (will continue to another
>>> node): TcpDiscoveryNode [id=927af8bb-e105-4332-baf3-072f921d09cd,
>>> addrs=[0:0:0:0:0:0:0:1%lo, 127.0.0.1, 192.168.30.22],
>>> sockAddrs=[0:0:0:0:0:0:0:1%lo:47500, /127.0.0.1:47500,
>>> slave-1/192.168.30.22:47500], discPort=47500, order=1, intOrder=1,
>>> lastExchangeTime=1498053228353, loc=false,
>>> ver=2.0.0#20170430-sha1:d4eef3c6,
>>> isClient=false]
>>> 2017-06-21 13:53:54,706 WARN [exchange-worker-#25%null%]
>>> dht.GridDhtAssignmentFetchFuture (Log4JLogger.java:warning(480)) -
>>> Failed to
>>> request affinity assignment from remote node (will continue to another
>>> node): TcpDiscoveryNode [id=927af8bb-e105-4332-baf3-072f921d09cd,
>>> addrs=[0:0:0:0:0:0:0:1%lo, 127.0.0.1, 192.168.30.22],
>>> sockAddrs=[0:0:0:0:0:0:0:1%lo:47500, /127.0.0.1:47500,
>>> slave-1/192.168.30.22:47500], discPort=47500, order=1, intOrder=1,
>>> lastExchangeTime=1498053228353, loc=false,
>>> ver=2.0.0#20170430-sha1:d4eef3c6,
>>> isClient=false]
>>> 2017-06-21 13:53:56,724 WARN [exchange-worker-#25%null%]
>>> dht.GridDhtAssignmentFetchFuture (Log4JLogger.java:warning(480)) -
>>> Failed to
>>> request affinity assignment from remote node (will continue to another
>>> node): TcpDiscoveryNode [id=927af8bb-e105-4332-baf3-072f921d09cd,
>>> addrs=[0:0:0:0:0:0:0:1%lo, 127.0.0.1, 192.168.30.22],
>>> sockAddrs=[0:0:0:0:0:0:0:1%lo:47500, /127.0.0.1:47500,
>>> slave-1/192.168.30.22:47500], discPort=47500, order=1, intOrder=1,
>>> lastExchangeTime=1498053228353, loc=false,
>>> ver=2.0.0#20170430-sha1:d4eef3c6,
>>> isClient=false]
>>> 2017-06-21 13:53:58,744 WARN [exchange-worker-#25%null%]
>>> dht.GridDhtAssignmentFetchFuture (Log4JLogger.java:warning(480)) -
>>> Failed to
>>> request affinity assignment from remote node (will continue to another
>>> node): TcpDiscoveryNode [id=927af8bb-e105-4332-baf3-072f921d09cd,
>>> addrs=[0:0:0:0:0:0:0:1%lo, 127.0.0.1, 192.168.30.22],
>>> sockAddrs=[0:0:0:0:0:0:0:1%lo:47500, /127.0.0.1:47500,
>>> slave-1/192.168.30.22:47500], discPort=47500, order=1, intOrder=1,
>>> lastExchangeTime=1498053228353, loc=false,
>>> ver=2.0.0#20170430-sha1:d4eef3c6,
>>> isClient=false]
>>> 2017-06-21 13:54:00,789 ERROR [exchange-worker-#25%null%]
>>> preloader.GridDhtPartitionsExchangeFuture (Log4JLogger.java:error(495))
>>> -
>>> Failed to reinitialize local partitions (preloading will be stopped):
>>> GridDhtPartitionExchangeId [topVer=AffinityTopologyVersion [topVer=4,
>>> minorTopVer=0], nodeId=2df6b461, evt=NODE_JOINED]
>>> class org.apache.ignite.IgniteCheckedException: Failed to send message
>>> (node
>>> may have left the grid or TCP connection cannot be established due to
>>> firewall issues) [node=TcpDiscoveryNode
>>> [id=927af8bb-e105-4332-baf3-072f921d09cd, addrs=[0:0:0:0:0:0:0:1%lo,
>>> 127.0.0.1, 192.168.30.22], sockAddrs=[0:0:0:0:0:0:0:1%lo:47500,
>>> /127.0.0.1:47500, slave-1/192.168.30.22:47500], discPort=47500, order=1,
>>> intOrder=1, lastExchangeTime=1498053228353, loc=false,
>>> ver=2.0.0#20170430-sha1:d4eef3c6, isClient=false], topic=TOPIC_CACHE,
>>> msg=GridDhtPartitionsSingleMessage [parts={-1448311745=GridDhtPar
>>> titionMap
>>> [moving=0, size=0], -2100569601=GridDhtPartitionMap [moving=0, size=0],
>>> 689859866=GridDhtPartitionMap [moving=0, size=0],
>>> -313790114=GridDhtPartitionMap [moving=0, size=0],
>>> -313518151=GridDhtPartitionMap [moving=0, size=0]},
>>> partCntrs={-1448311745={}, -2100569601={}, 689859866={}, -313790114={},
>>> -313518151={}}, ex=null, client=true, compress=true,
>>> super=GridDhtPartitionsAbstractMessage [exchId=GridDhtPartitionExchan
>>> geId
>>> [topVer=AffinityTopologyVersion [topVer=4, minorTopVer=0],
>>> nodeId=2df6b461,
>>> evt=NODE_JOINED], lastVer=GridCacheVersion [topVer=0,
>>> order=1498053227978,
>>> nodeOrder=0], flags=1, super=GridCacheMessage [msgId=6, depInfo=null,
>>> err=null, skipPrepare=false, cacheId=0, cacheId=0]]], policy=2]
>>> at
>>> org.apache.ignite.internal.managers.communication.GridIoMana
>>> ger.send(GridIoManager.java:1334)
>>> at
>>> org.apache.ignite.internal.managers.communication.GridIoMana
>>> ger.sendToGridTopic(GridIoManager.java:1398)
>>> at
>>> org.apache.ignite.internal.processors.cache.GridCacheIoManag
>>> er.send(GridCacheIoManager.java:946)
>>> at
>>> org.apache.ignite.internal.processors.cache.distributed.dht.
>>> preloader.GridDhtPartitionsExchangeFuture.sendLocalPartition
>>> s(GridDhtPartitionsExchangeFuture.java:1094)
>>> at
>>> org.apache.ignite.internal.processors.cache.distributed.dht.
>>> preloader.GridDhtPartitionsExchangeFuture.clientOnlyExchange
>>> (GridDhtPartitionsExchangeFuture.java:793)
>>> at
>>> org.apache.ignite.internal.processors.cache.distributed.dht.
>>> preloader.GridDhtPartitionsExchangeFuture.init(GridDhtPartit
>>> ionsExchangeFuture.java:581)
>>> at
>>> org.apache.ignite.internal.processors.cache.GridCachePartiti
>>> onExchangeManager$ExchangeWorker.body(GridCachePartitionExch
>>> angeManager.java:1806)
>>> at
>>> org.apache.ignite.internal.util.worker.GridWorker.run(GridWo
>>> rker.java:110)
>>> at java.lang.Thread.run(Thread.java:748)
>>> Caused by: class org.apache.ignite.spi.IgniteSpiException: Failed to
>>> send
>>> message to remote node: TcpDiscoveryNode
>>> [id=927af8bb-e105-4332-baf3-072f921d09cd, addrs=[0:0:0:0:0:0:0:1%lo,
>>> 127.0.0.1, 192.168.30.22], sockAddrs=[0:0:0:0:0:0:0:1%lo:47500,
>>> /127.0.0.1:47500, slave-1/192.168.30.22:47500], discPort=47500, order=1,
>>> intOrder=1, lastExchangeTime=1498053228353, loc=false,
>>> ver=2.0.0#20170430-sha1:d4eef3c6, isClient=false]
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> sendMessage0(TcpCommunicationSpi.java:2483)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> sendMessage(TcpCommunicationSpi.java:2419)
>>> at
>>> org.apache.ignite.internal.managers.communication.GridIoMana
>>> ger.send(GridIoManager.java:1329)
>>> ... 8 more
>>> Caused by: class org.apache.ignite.IgniteCheckedException:
>>> java.lang.NullPointerException
>>> at org.apache.ignite.internal.util.IgniteUtils.cast(IgniteUtils
>>> .java:7242)
>>> at
>>> org.apache.ignite.internal.util.future.GridFutureAdapter.res
>>> olve(GridFutureAdapter.java:258)
>>> at
>>> org.apache.ignite.internal.util.future.GridFutureAdapter.get
>>> 0(GridFutureAdapter.java:170)
>>> at
>>> org.apache.ignite.internal.util.future.GridFutureAdapter.get
>>> (GridFutureAdapter.java:139)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> reserveClient(TcpCommunicationSpi.java:2630)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> sendMessage0(TcpCommunicationSpi.java:2455)
>>> ... 10 more
>>> Caused by: java.util.concurrent.ExecutionException:
>>> java.lang.NullPointerException
>>> at java.util.concurrent.FutureTask.report(FutureTask.java:122)
>>> at java.util.concurrent.FutureTask.get(FutureTask.java:192)
>>> at
>>> org.apache.ignite.internal.util.IgniteUtils.filterReachable(
>>> IgniteUtils.java:1895)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> createTcpClient(TcpCommunicationSpi.java:2891)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> createNioClient(TcpCommunicationSpi.java:2702)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> reserveClient(TcpCommunicationSpi.java:2594)
>>> ... 11 more
>>> Caused by: java.lang.NullPointerException
>>> at
>>> org.apache.ignite.internal.util.IgniteUtils.reachable(Ignite
>>> Utils.java:2102)
>>> at
>>> org.apache.ignite.internal.util.IgniteUtils$18.run(IgniteUti
>>> ls.java:1884)
>>> at java.util.concurrent.Executors$RunnableAdapter.call(Executor
>>> s.java:511)
>>> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
>>> at
>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPool
>>> Executor.java:1142)
>>> at
>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoo
>>> lExecutor.java:617)
>>> ... 1 more
>>> 2017-06-21 13:54:00,798 ERROR [main] internal.IgniteKernal
>>> (Log4JLogger.java:error(495)) - Got exception while starting (will
>>> rollback
>>> startup routine).
>>> class org.apache.ignite.IgniteCheckedException: Failed to send message
>>> (node
>>> may have left the grid or TCP connection cannot be established due to
>>> firewall issues) [node=TcpDiscoveryNode
>>> [id=927af8bb-e105-4332-baf3-072f921d09cd, addrs=[0:0:0:0:0:0:0:1%lo,
>>> 127.0.0.1, 192.168.30.22], sockAddrs=[0:0:0:0:0:0:0:1%lo:47500,
>>> /127.0.0.1:47500, slave-1/192.168.30.22:47500], discPort=47500, order=1,
>>> intOrder=1, lastExchangeTime=1498053228353, loc=false,
>>> ver=2.0.0#20170430-sha1:d4eef3c6, isClient=false], topic=TOPIC_CACHE,
>>> msg=GridDhtPartitionsSingleMessage [parts={-1448311745=GridDhtPar
>>> titionMap
>>> [moving=0, size=0], -2100569601=GridDhtPartitionMap [moving=0, size=0],
>>> 689859866=GridDhtPartitionMap [moving=0, size=0],
>>> -313790114=GridDhtPartitionMap [moving=0, size=0],
>>> -313518151=GridDhtPartitionMap [moving=0, size=0]},
>>> partCntrs={-1448311745={}, -2100569601={}, 689859866={}, -313790114={},
>>> -313518151={}}, ex=null, client=true, compress=true,
>>> super=GridDhtPartitionsAbstractMessage [exchId=GridDhtPartitionExchan
>>> geId
>>> [topVer=AffinityTopologyVersion [topVer=4, minorTopVer=0],
>>> nodeId=2df6b461,
>>> evt=NODE_JOINED], lastVer=GridCacheVersion [topVer=0,
>>> order=1498053227978,
>>> nodeOrder=0], flags=1, super=GridCacheMessage [msgId=6, depInfo=null,
>>> err=null, skipPrepare=false, cacheId=0, cacheId=0]]], policy=2]
>>> at
>>> org.apache.ignite.internal.managers.communication.GridIoMana
>>> ger.send(GridIoManager.java:1334)
>>> at
>>> org.apache.ignite.internal.managers.communication.GridIoMana
>>> ger.sendToGridTopic(GridIoManager.java:1398)
>>> at
>>> org.apache.ignite.internal.processors.cache.GridCacheIoManag
>>> er.send(GridCacheIoManager.java:946)
>>> at
>>> org.apache.ignite.internal.processors.cache.distributed.dht.
>>> preloader.GridDhtPartitionsExchangeFuture.sendLocalPartition
>>> s(GridDhtPartitionsExchangeFuture.java:1094)
>>> at
>>> org.apache.ignite.internal.processors.cache.distributed.dht.
>>> preloader.GridDhtPartitionsExchangeFuture.clientOnlyExchange
>>> (GridDhtPartitionsExchangeFuture.java:793)
>>> at
>>> org.apache.ignite.internal.processors.cache.distributed.dht.
>>> preloader.GridDhtPartitionsExchangeFuture.init(GridDhtPartit
>>> ionsExchangeFuture.java:581)
>>> at
>>> org.apache.ignite.internal.processors.cache.GridCachePartiti
>>> onExchangeManager$ExchangeWorker.body(GridCachePartitionExch
>>> angeManager.java:1806)
>>> at
>>> org.apache.ignite.internal.util.worker.GridWorker.run(GridWo
>>> rker.java:110)
>>> at java.lang.Thread.run(Thread.java:748)
>>> Caused by: class org.apache.ignite.spi.IgniteSpiException: Failed to
>>> send
>>> message to remote node: TcpDiscoveryNode
>>> [id=927af8bb-e105-4332-baf3-072f921d09cd, addrs=[0:0:0:0:0:0:0:1%lo,
>>> 127.0.0.1, 192.168.30.22], sockAddrs=[0:0:0:0:0:0:0:1%lo:47500,
>>> /127.0.0.1:47500, slave-1/192.168.30.22:47500], discPort=47500, order=1,
>>> intOrder=1, lastExchangeTime=1498053228353, loc=false,
>>> ver=2.0.0#20170430-sha1:d4eef3c6, isClient=false]
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> sendMessage0(TcpCommunicationSpi.java:2483)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> sendMessage(TcpCommunicationSpi.java:2419)
>>> at
>>> org.apache.ignite.internal.managers.communication.GridIoMana
>>> ger.send(GridIoManager.java:1329)
>>> ... 8 more
>>> Caused by: class org.apache.ignite.IgniteCheckedException:
>>> java.lang.NullPointerException
>>> at org.apache.ignite.internal.util.IgniteUtils.cast(IgniteUtils
>>> .java:7242)
>>> at
>>> org.apache.ignite.internal.util.future.GridFutureAdapter.res
>>> olve(GridFutureAdapter.java:258)
>>> at
>>> org.apache.ignite.internal.util.future.GridFutureAdapter.get
>>> 0(GridFutureAdapter.java:170)
>>> at
>>> org.apache.ignite.internal.util.future.GridFutureAdapter.get
>>> (GridFutureAdapter.java:139)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> reserveClient(TcpCommunicationSpi.java:2630)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> sendMessage0(TcpCommunicationSpi.java:2455)
>>> ... 10 more
>>> Caused by: java.util.concurrent.ExecutionException:
>>> java.lang.NullPointerException
>>> at java.util.concurrent.FutureTask.report(FutureTask.java:122)
>>> at java.util.concurrent.FutureTask.get(FutureTask.java:192)
>>> at
>>> org.apache.ignite.internal.util.IgniteUtils.filterReachable(
>>> IgniteUtils.java:1895)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> createTcpClient(TcpCommunicationSpi.java:2891)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> createNioClient(TcpCommunicationSpi.java:2702)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> reserveClient(TcpCommunicationSpi.java:2594)
>>> ... 11 more
>>> Caused by: java.lang.NullPointerException
>>> at
>>> org.apache.ignite.internal.util.IgniteUtils.reachable(Ignite
>>> Utils.java:2102)
>>> at
>>> org.apache.ignite.internal.util.IgniteUtils$18.run(IgniteUti
>>> ls.java:1884)
>>> at java.util.concurrent.Executors$RunnableAdapter.call(Executor
>>> s.java:511)
>>> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
>>> at
>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPool
>>> Executor.java:1142)
>>> at
>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoo
>>> lExecutor.java:617)
>>> ... 1 more
>>> 2017-06-21 13:54:00,804 ERROR [exchange-worker-#25%null%]
>>> cache.GridCachePartitionExchangeManager (Log4JLogger.java:error(495)) -
>>> Failed to wait for completion of partition map exchange (preloading will
>>> not
>>> start): GridDhtPartitionsExchangeFuture [dummy=false,
>>> forcePreload=false,
>>> reassign=false, discoEvt=DiscoveryEvent [evtNode=TcpDiscoveryNode
>>> [id=2df6b461-723c-45d4-9bcc-02daab91fb74, addrs=[127.0.0.1,
>>> 192.168.30.5],
>>> sockAddrs=[Master/192.168.30.5:0, /127.0.0.1:0], discPort=0, order=4,
>>> intOrder=0, lastExchangeTime=1498053228293, loc=true,
>>> ver=2.0.0#20170430-sha1:d4eef3c6, isClient=true], topVer=4,
>>> nodeId8=2df6b461, msg=null, type=NODE_JOINED, tstamp=1498053228384],
>>> crd=TcpDiscoveryNode [id=927af8bb-e105-4332-baf3-072f921d09cd,
>>> addrs=[0:0:0:0:0:0:0:1%lo, 127.0.0.1, 192.168.30.22],
>>> sockAddrs=[0:0:0:0:0:0:0:1%lo:47500, /127.0.0.1:47500,
>>> slave-1/192.168.30.22:47500], discPort=47500, order=1, intOrder=1,
>>> lastExchangeTime=1498053228353, loc=false,
>>> ver=2.0.0#20170430-sha1:d4eef3c6,
>>> isClient=false], exchId=GridDhtPartitionExchangeId
>>> [topVer=AffinityTopologyVersion [topVer=4, minorTopVer=0],
>>> nodeId=2df6b461,
>>> evt=NODE_JOINED], added=false, initFut=GridFutureAdapter
>>> [ignoreInterrupts=false, state=DONE, res=false, hash=1930617560],
>>> init=false, lastVer=null, partReleaseFut=null, affChangeMsg=null,
>>> skipPreload=true, clientOnlyExchange=true, initTs=1498053228616,
>>> centralizedAff=false, changeGlobalStateE=null,
>>> exchangeOnChangeGlobalState=false, forcedRebFut=null, evtLatch=0,
>>> remaining=[927af8bb-e105-4332-baf3-072f921d09cd],
>>> srvNodes=[TcpDiscoveryNode
>>> [id=927af8bb-e105-4332-baf3-072f921d09cd, addrs=[0:0:0:0:0:0:0:1%lo,
>>> 127.0.0.1, 192.168.30.22], sockAddrs=[0:0:0:0:0:0:0:1%lo:47500,
>>> /127.0.0.1:47500, slave-1/192.168.30.22:47500], discPort=47500, order=1,
>>> intOrder=1, lastExchangeTime=1498053228353, loc=false,
>>> ver=2.0.0#20170430-sha1:d4eef3c6, isClient=false]],
>>> super=GridFutureAdapter
>>> [ignoreInterrupts=false, state=DONE, res=class
>>> o.a.i.IgniteCheckedException:
>>> Failed to send message (node may have left the grid or TCP connection
>>> cannot
>>> be established due to firewall issues) [node=TcpDiscoveryNode
>>> [id=927af8bb-e105-4332-baf3-072f921d09cd, addrs=[0:0:0:0:0:0:0:1%lo,
>>> 127.0.0.1, 192.168.30.22], sockAddrs=[0:0:0:0:0:0:0:1%lo:47500,
>>> /127.0.0.1:47500, slave-1/192.168.30.22:47500], discPort=47500, order=1,
>>> intOrder=1, lastExchangeTime=1498053228353, loc=false,
>>> ver=2.0.0#20170430-sha1:d4eef3c6, isClient=false], topic=TOPIC_CACHE,
>>> msg=GridDhtPartitionsSingleMessage [parts={-1448311745=GridDhtPar
>>> titionMap
>>> [moving=0, size=0], -2100569601=GridDhtPartitionMap [moving=0, size=0],
>>> 689859866=GridDhtPartitionMap [moving=0, size=0],
>>> -313790114=GridDhtPartitionMap [moving=0, size=0],
>>> -313518151=GridDhtPartitionMap [moving=0, size=0]},
>>> partCntrs={-1448311745={}, -2100569601={}, 689859866={}, -313790114={},
>>> -313518151={}}, ex=null, client=true, compress=true,
>>> super=GridDhtPartitionsAbstractMessage [exchId=GridDhtPartitionExchan
>>> geId
>>> [topVer=AffinityTopologyVersion [topVer=4, minorTopVer=0],
>>> nodeId=2df6b461,
>>> evt=NODE_JOINED], lastVer=GridCacheVersion [topVer=0,
>>> order=1498053227978,
>>> nodeOrder=0], flags=1, super=GridCacheMessage [msgId=6, depInfo=null,
>>> err=null, skipPrepare=false, cacheId=0, cacheId=0]]], policy=2],
>>> hash=1242579201]]
>>> class org.apache.ignite.IgniteCheckedException: Failed to send message
>>> (node
>>> may have left the grid or TCP connection cannot be established due to
>>> firewall issues) [node=TcpDiscoveryNode
>>> [id=927af8bb-e105-4332-baf3-072f921d09cd, addrs=[0:0:0:0:0:0:0:1%lo,
>>> 127.0.0.1, 192.168.30.22], sockAddrs=[0:0:0:0:0:0:0:1%lo:47500,
>>> /127.0.0.1:47500, slave-1/192.168.30.22:47500], discPort=47500, order=1,
>>> intOrder=1, lastExchangeTime=1498053228353, loc=false,
>>> ver=2.0.0#20170430-sha1:d4eef3c6, isClient=false], topic=TOPIC_CACHE,
>>> msg=GridDhtPartitionsSingleMessage [parts={-1448311745=GridDhtPar
>>> titionMap
>>> [moving=0, size=0], -2100569601=GridDhtPartitionMap [moving=0, size=0],
>>> 689859866=GridDhtPartitionMap [moving=0, size=0],
>>> -313790114=GridDhtPartitionMap [moving=0, size=0],
>>> -313518151=GridDhtPartitionMap [moving=0, size=0]},
>>> partCntrs={-1448311745={}, -2100569601={}, 689859866={}, -313790114={},
>>> -313518151={}}, ex=null, client=true, compress=true,
>>> super=GridDhtPartitionsAbstractMessage [exchId=GridDhtPartitionExchan
>>> geId
>>> [topVer=AffinityTopologyVersion [topVer=4, minorTopVer=0],
>>> nodeId=2df6b461,
>>> evt=NODE_JOINED], lastVer=GridCacheVersion [topVer=0,
>>> order=1498053227978,
>>> nodeOrder=0], flags=1, super=GridCacheMessage [msgId=6, depInfo=null,
>>> err=null, skipPrepare=false, cacheId=0, cacheId=0]]], policy=2]
>>> at
>>> org.apache.ignite.internal.managers.communication.GridIoMana
>>> ger.send(GridIoManager.java:1334)
>>> at
>>> org.apache.ignite.internal.managers.communication.GridIoMana
>>> ger.sendToGridTopic(GridIoManager.java:1398)
>>> at
>>> org.apache.ignite.internal.processors.cache.GridCacheIoManag
>>> er.send(GridCacheIoManager.java:946)
>>> at
>>> org.apache.ignite.internal.processors.cache.distributed.dht.
>>> preloader.GridDhtPartitionsExchangeFuture.sendLocalPartition
>>> s(GridDhtPartitionsExchangeFuture.java:1094)
>>> at
>>> org.apache.ignite.internal.processors.cache.distributed.dht.
>>> preloader.GridDhtPartitionsExchangeFuture.clientOnlyExchange
>>> (GridDhtPartitionsExchangeFuture.java:793)
>>> at
>>> org.apache.ignite.internal.processors.cache.distributed.dht.
>>> preloader.GridDhtPartitionsExchangeFuture.init(GridDhtPartit
>>> ionsExchangeFuture.java:581)
>>> at
>>> org.apache.ignite.internal.processors.cache.GridCachePartiti
>>> onExchangeManager$ExchangeWorker.body(GridCachePartitionExch
>>> angeManager.java:1806)
>>> at
>>> org.apache.ignite.internal.util.worker.GridWorker.run(GridWo
>>> rker.java:110)
>>> at java.lang.Thread.run(Thread.java:748)
>>> Caused by: class org.apache.ignite.spi.IgniteSpiException: Failed to
>>> send
>>> message to remote node: TcpDiscoveryNode
>>> [id=927af8bb-e105-4332-baf3-072f921d09cd, addrs=[0:0:0:0:0:0:0:1%lo,
>>> 127.0.0.1, 192.168.30.22], sockAddrs=[0:0:0:0:0:0:0:1%lo:47500,
>>> /127.0.0.1:47500, slave-1/192.168.30.22:47500], discPort=47500, order=1,
>>> intOrder=1, lastExchangeTime=1498053228353, loc=false,
>>> ver=2.0.0#20170430-sha1:d4eef3c6, isClient=false]
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> sendMessage0(TcpCommunicationSpi.java:2483)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> sendMessage(TcpCommunicationSpi.java:2419)
>>> at
>>> org.apache.ignite.internal.managers.communication.GridIoMana
>>> ger.send(GridIoManager.java:1329)
>>> ... 8 more
>>> Caused by: class org.apache.ignite.IgniteCheckedException:
>>> java.lang.NullPointerException
>>> at org.apache.ignite.internal.util.IgniteUtils.cast(IgniteUtils
>>> .java:7242)
>>> at
>>> org.apache.ignite.internal.util.future.GridFutureAdapter.res
>>> olve(GridFutureAdapter.java:258)
>>> at
>>> org.apache.ignite.internal.util.future.GridFutureAdapter.get
>>> 0(GridFutureAdapter.java:170)
>>> at
>>> org.apache.ignite.internal.util.future.GridFutureAdapter.get
>>> (GridFutureAdapter.java:139)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> reserveClient(TcpCommunicationSpi.java:2630)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> sendMessage0(TcpCommunicationSpi.java:2455)
>>> ... 10 more
>>> Caused by: java.util.concurrent.ExecutionException:
>>> java.lang.NullPointerException
>>> at java.util.concurrent.FutureTask.report(FutureTask.java:122)
>>> at java.util.concurrent.FutureTask.get(FutureTask.java:192)
>>> at
>>> org.apache.ignite.internal.util.IgniteUtils.filterReachable(
>>> IgniteUtils.java:1895)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> createTcpClient(TcpCommunicationSpi.java:2891)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> createNioClient(TcpCommunicationSpi.java:2702)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> reserveClient(TcpCommunicationSpi.java:2594)
>>> ... 11 more
>>> Caused by: java.lang.NullPointerException
>>> at
>>> org.apache.ignite.internal.util.IgniteUtils.reachable(Ignite
>>> Utils.java:2102)
>>> at
>>> org.apache.ignite.internal.util.IgniteUtils$18.run(IgniteUti
>>> ls.java:1884)
>>> at java.util.concurrent.Executors$RunnableAdapter.call(Executor
>>> s.java:511)
>>> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
>>> at
>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPool
>>> Executor.java:1142)
>>> at
>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoo
>>> lExecutor.java:617)
>>> ... 1 more
>>> 2017-06-21 13:54:00,825 INFO [main] cache.GridCacheProcessor
>>> (Log4JLogger.java:info(475)) - Stopped cache: ignite-sys-cache
>>> 2017-06-21 13:54:00,825 INFO [main] cache.GridCacheProcessor
>>> (Log4JLogger.java:info(475)) - Stopped cache: ignite-hadoop-mr-sys-cache
>>> 2017-06-21 13:54:00,826 INFO [main] cache.GridCacheProcessor
>>> (Log4JLogger.java:info(475)) - Stopped cache: ignite-atomics-sys-cache
>>> 2017-06-21 13:54:00,826 INFO [main] cache.GridCacheProcessor
>>> (Log4JLogger.java:info(475)) - Stopped cache: igfs-internal-igfs-meta
>>> 2017-06-21 13:54:00,827 INFO [main] cache.GridCacheProcessor
>>> (Log4JLogger.java:info(475)) - Stopped cache: igfs-internal-igfs-data
>>> 2017-06-21 13:54:00,836 INFO [main] internal.IgniteKernal
>>> (Log4JLogger.java:info(475)) -
>>>
>>> >>> +-----------------------------------------------------------
>>> ----------------------+
>>> >>> Ignite ver. 2.0.0#20170430-sha1:d4eef3c68f
>>> f116ee34bc13648cd82c640b3ea072
>>> >>> stopped OK
>>> >>> +-----------------------------------------------------------
>>> ----------------------+
>>> >>> Grid uptime: 00:00:14:004
>>>
>>>
>>> Exception in thread "main" class org.apache.ignite.spi.IgniteSp
>>> iException:
>>> Failed to send message to remote node: TcpDiscoveryNode
>>> [id=927af8bb-e105-4332-baf3-072f921d09cd, addrs=[0:0:0:0:0:0:0:1%lo,
>>> 127.0.0.1, 192.168.30.22], sockAddrs=[0:0:0:0:0:0:0:1%lo:47500,
>>> /127.0.0.1:47500, slave-1/192.168.30.22:47500], discPort=47500, order=1,
>>> intOrder=1, lastExchangeTime=1498053228353, loc=false,
>>> ver=2.0.0#20170430-sha1:d4eef3c6, isClient=false]
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> sendMessage0(TcpCommunicationSpi.java:2483)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> sendMessage(TcpCommunicationSpi.java:2419)
>>> at
>>> org.apache.ignite.internal.managers.communication.GridIoMana
>>> ger.send(GridIoManager.java:1329)
>>> at
>>> org.apache.ignite.internal.managers.communication.GridIoMana
>>> ger.sendToGridTopic(GridIoManager.java:1398)
>>> at
>>> org.apache.ignite.internal.processors.cache.GridCacheIoManag
>>> er.send(GridCacheIoManager.java:946)
>>> at
>>> org.apache.ignite.internal.processors.cache.distributed.dht.
>>> preloader.GridDhtPartitionsExchangeFuture.sendLocalPartition
>>> s(GridDhtPartitionsExchangeFuture.java:1094)
>>> at
>>> org.apache.ignite.internal.processors.cache.distributed.dht.
>>> preloader.GridDhtPartitionsExchangeFuture.clientOnlyExchange
>>> (GridDhtPartitionsExchangeFuture.java:793)
>>> at
>>> org.apache.ignite.internal.processors.cache.distributed.dht.
>>> preloader.GridDhtPartitionsExchangeFuture.init(GridDhtPartit
>>> ionsExchangeFuture.java:581)
>>> at
>>> org.apache.ignite.internal.processors.cache.GridCachePartiti
>>> onExchangeManager$ExchangeWorker.body(GridCachePartitionExch
>>> angeManager.java:1806)
>>> at
>>> org.apache.ignite.internal.util.worker.GridWorker.run(GridWo
>>> rker.java:110)
>>> at java.lang.Thread.run(Thread.java:748)
>>> Caused by: class org.apache.ignite.IgniteCheckedException:
>>> java.lang.NullPointerException
>>> at org.apache.ignite.internal.util.IgniteUtils.cast(IgniteUtils
>>> .java:7242)
>>> at
>>> org.apache.ignite.internal.util.future.GridFutureAdapter.res
>>> olve(GridFutureAdapter.java:258)
>>> at
>>> org.apache.ignite.internal.util.future.GridFutureAdapter.get
>>> 0(GridFutureAdapter.java:170)
>>> at
>>> org.apache.ignite.internal.util.future.GridFutureAdapter.get
>>> (GridFutureAdapter.java:139)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> reserveClient(TcpCommunicationSpi.java:2630)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> sendMessage0(TcpCommunicationSpi.java:2455)
>>> ... 10 more
>>> Caused by: java.util.concurrent.ExecutionException:
>>> java.lang.NullPointerException
>>> at java.util.concurrent.FutureTask.report(FutureTask.java:122)
>>> at java.util.concurrent.FutureTask.get(FutureTask.java:192)
>>> at
>>> org.apache.ignite.internal.util.IgniteUtils.filterReachable(
>>> IgniteUtils.java:1895)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> createTcpClient(TcpCommunicationSpi.java:2891)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> createNioClient(TcpCommunicationSpi.java:2702)
>>> at
>>> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.
>>> reserveClient(TcpCommunicationSpi.java:2594)
>>> ... 11 more
>>> Caused by: java.lang.NullPointerException
>>> at
>>> org.apache.ignite.internal.util.IgniteUtils.reachable(Ignite
>>> Utils.java:2102)
>>> at
>>> org.apache.ignite.internal.util.IgniteUtils$18.run(IgniteUti
>>> ls.java:1884)
>>> at java.util.concurrent.Executors$RunnableAdapter.call(Executor
>>> s.java:511)
>>> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
>>> at
>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPool
>>> Executor.java:1142)
>>> at
>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoo
>>> lExecutor.java:617)
>>> ... 1 more
>>>
>>>
>>> The IPDiscovery found the two node server try to connect and for a little
>>> bit of time they connect with him but it failed to send message with
>>> server
>>> node.... I don't think it's a problem of Port because they are open...
>>> Any
>>> suggestion?
>>>
>>> the code of WordCount
>>>
>>> public static void main(String args[]) throws Exception {
>>>
>>> //TcpDiscoverySpi spi = new TcpDiscoverySpi();
>>>
>>> //TcpDiscoveryVmIpFinder ipFinder = new
>>> TcpDiscoveryVmIpFinder();
>>>
>>> // Set initial IP addresses.
>>> // Note that you can optionally specify a port or a port
>>> range.
>>> //ipFinder.setAddresses(Arrays.asList("192.168.30.99",
>>> "192.168.30.22"));
>>>
>>> //spi.setIpFinder(ipFinder);
>>>
>>> //IgniteConfiguration cfg = new IgniteConfiguration();
>>>
>>> // Override default discovery SPI.
>>> //cfg.setDiscoverySpi(spi);
>>>
>>> // Start Ignite node.
>>> Ignition.setClientMode(true);
>>>
>>>
>>>
>>> try(Ignite ignite =
>>> Ignition.start("/home/hduser/apache-ignite-2.0.0-src/config/
>>> hadoop/default-config.xml")){
>>>
>>> CacheConfiguration<Integer ,String> cfg2 = new
>>> CacheConfiguration<>();
>>>
>>> IgniteCache<Integer, String> cache;
>>>
>>> cfg2.setName("demoCache");
>>> cfg2.setAtomicityMode(CacheAto
>>> micityMode.TRANSACTIONAL);
>>>
>>> //cache = ignite.getOrCreateCache(cfg2);
>>>
>>> //cache.put(1,"uno");
>>> //cache.put(2,"due");
>>>
>>> //System.out.println(cache.get(1));
>>>
>>> //System.out.println(cache.get(2));
>>>
>>>
>>> int res = ToolRunner.run(new WordCountIgnite(),
>>> args);
>>> System.exit(res);
>>> }
>>> }
>>>
>>> Else i try to put manually IP of server but it's the same. It crash
>>> before
>>> start cache, i try just to connect without create cache but it's the
>>> same.
>>> Any suggestion?
>>>
>>> Thanks
>>>
>>>
>>>
>>> --
>>> View this message in context: http://apache-ignite-users.705
>>> 18.x6.nabble.com/Hadoop-and-Ignite-Problem-grid-cache-tp14028.html
>>> Sent from the Apache Ignite Users mailing list archive at Nabble.com.
>>>
>>
>>
>
