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 <mimmo.celano1...@gmail.com>:
> 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/default-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-common-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=GridDhtPartitionMap
> [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=GridDhtPartitionExchangeId
> [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.GridIoManager.send(
> GridIoManager.java:1334)
> at
> org.apache.ignite.internal.managers.communication.
> GridIoManager.sendToGridTopic(GridIoManager.java:1398)
> at
> org.apache.ignite.internal.processors.cache.GridCacheIoManager.send(
> GridCacheIoManager.java:946)
> at
> org.apache.ignite.internal.processors.cache.distributed.dht.preloader.
> GridDhtPartitionsExchangeFuture.sendLocalPartitions(
> 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(GridDhtPartitionsExchangeFutur
> e.java:581)
> at
> org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeMana
> ger$ExchangeWorker.body(GridCachePartitionExchangeManager.java:1806)
> at
> org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.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.GridIoManager.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.
> resolve(GridFutureAdapter.java:258)
> at
> org.apache.ignite.internal.util.future.GridFutureAdapter.
> get0(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(
> IgniteUtils.java:2102)
> at
> org.apache.ignite.internal.util.IgniteUtils$18.run(IgniteUtils.java:1884)
> at java.util.concurrent.Executors$RunnableAdapter.
> call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(
> ThreadPoolExecutor.java:1142)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(
> ThreadPoolExecutor.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=GridDhtPartitionMap
> [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=GridDhtPartitionExchangeId
> [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.GridIoManager.send(
> GridIoManager.java:1334)
> at
> org.apache.ignite.internal.managers.communication.
> GridIoManager.sendToGridTopic(GridIoManager.java:1398)
> at
> org.apache.ignite.internal.processors.cache.GridCacheIoManager.send(
> GridCacheIoManager.java:946)
> at
> org.apache.ignite.internal.processors.cache.distributed.dht.preloader.
> GridDhtPartitionsExchangeFuture.sendLocalPartitions(
> 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(GridDhtPartitionsExchangeFutur
> e.java:581)
> at
> org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeMana
> ger$ExchangeWorker.body(GridCachePartitionExchangeManager.java:1806)
> at
> org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.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.GridIoManager.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.
> resolve(GridFutureAdapter.java:258)
> at
> org.apache.ignite.internal.util.future.GridFutureAdapter.
> get0(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(
> IgniteUtils.java:2102)
> at
> org.apache.ignite.internal.util.IgniteUtils$18.run(IgniteUtils.java:1884)
> at java.util.concurrent.Executors$RunnableAdapter.
> call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(
> ThreadPoolExecutor.java:1142)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(
> ThreadPoolExecutor.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=GridDhtPartitionMap
> [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=GridDhtPartitionExchangeId
> [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=GridDhtPartitionMap
> [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=GridDhtPartitionExchangeId
> [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.GridIoManager.send(
> GridIoManager.java:1334)
> at
> org.apache.ignite.internal.managers.communication.
> GridIoManager.sendToGridTopic(GridIoManager.java:1398)
> at
> org.apache.ignite.internal.processors.cache.GridCacheIoManager.send(
> GridCacheIoManager.java:946)
> at
> org.apache.ignite.internal.processors.cache.distributed.dht.preloader.
> GridDhtPartitionsExchangeFuture.sendLocalPartitions(
> 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(GridDhtPartitionsExchangeFutur
> e.java:581)
> at
> org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeMana
> ger$ExchangeWorker.body(GridCachePartitionExchangeManager.java:1806)
> at
> org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.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.GridIoManager.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.
> resolve(GridFutureAdapter.java:258)
> at
> org.apache.ignite.internal.util.future.GridFutureAdapter.
> get0(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(
> IgniteUtils.java:2102)
> at
> org.apache.ignite.internal.util.IgniteUtils$18.run(IgniteUtils.java:1884)
> at java.util.concurrent.Executors$RunnableAdapter.
> call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(
> ThreadPoolExecutor.java:1142)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(
> ThreadPoolExecutor.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:d4eef3c68ff116ee34bc13648cd82c
> 640b3ea072
> >>> stopped OK
> >>> +-----------------------------------------------------------
> ----------------------+
> >>> Grid uptime: 00:00:14:004
>
>
> Exception in thread "main" 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.GridIoManager.send(
> GridIoManager.java:1329)
> at
> org.apache.ignite.internal.managers.communication.
> GridIoManager.sendToGridTopic(GridIoManager.java:1398)
> at
> org.apache.ignite.internal.processors.cache.GridCacheIoManager.send(
> GridCacheIoManager.java:946)
> at
> org.apache.ignite.internal.processors.cache.distributed.dht.preloader.
> GridDhtPartitionsExchangeFuture.sendLocalPartitions(
> 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(GridDhtPartitionsExchangeFutur
> e.java:581)
> at
> org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeMana
> ger$ExchangeWorker.body(GridCachePartitionExchangeManager.java:1806)
> at
> org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.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.
> resolve(GridFutureAdapter.java:258)
> at
> org.apache.ignite.internal.util.future.GridFutureAdapter.
> get0(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(
> IgniteUtils.java:2102)
> at
> org.apache.ignite.internal.util.IgniteUtils$18.run(IgniteUtils.java:1884)
> at java.util.concurrent.Executors$RunnableAdapter.
> call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(
> ThreadPoolExecutor.java:1142)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(
> ThreadPoolExecutor.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(CacheAtomicityMode.
> 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.
> 70518.x6.nabble.com/Hadoop-and-Ignite-Problem-grid-cache-tp14028.html
> Sent from the Apache Ignite Users mailing list archive at Nabble.com.
>
