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
ture.sendLocalPartitions(GridDhtPar
>> titionsExchangeFuture.java:1094)
>> at
>> org.apache.ignite.internal.processors.cache.distributed.dht.
>> preloader.GridDhtPartitionsExchangeFuture.clientOnlyExchange(GridDhtPart
>> itionsExchangeFuture.java:793)
>>
on
> 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)
>
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(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(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 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.
>>
>
>
ava: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)
>
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.
