Thank you, worked like a charm! On Thu, Oct 17, 2019 at 5:14 AM Denis Mekhanikov <dmekhani...@gmail.com> wrote:
> I answered to you on stackoverflow: > https://stackoverflow.com/questions/58422096/failing-to-connect-apache-ignite-cluster > You need to use the port 10800 for thin clients instead of 47xxx > > Denis > On 17 Oct 2019, 00:08 +0300, sri hari kali charan Tummala < > kali.tumm...@gmail.com>, wrote: > > I even tried with simple scala code still no luck! > > Error:- > Failed to connect to any address from IP finder (will retry to join > topology every 2000 ms; change 'reconnectDelay' to configure the frequency > of retries): > > package com.ignite.examples.igniteStartup > > import org.apache.ignite.Ignite > import org.apache.ignite.IgniteCache > import org.apache.ignite.Ignition > import org.apache.ignite.configuration.IgniteConfiguration > import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi > import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder > import org.apache.ignite.configuration.IgniteConfiguration > import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi > import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder > import java.util.Arrays > import java.util.List > import scala.collection.JavaConversions._ > > object IgniteClientConnection { > def main(args: Array[String]): Unit = { > > val spi = new TcpDiscoverySpi > val ipFinder = new TcpDiscoveryVmIpFinder > val hostList: List[String] = > Arrays.asList(("ec2-100-25-173-220:47500..47509," + > "ec2-100-25-173-220.compute-1.amazonaws.com:47500..47509," + > "3.86.250.240:47500..47509," + > "172.31.81.211:47500..47509," + > "100.25.173.220:47500..47509").split(","): _*) > > ipFinder.setAddresses(hostList) > spi.setIpFinder(ipFinder) > val cfg = new IgniteConfiguration > cfg.setDiscoverySpi(spi) > cfg.setClientMode(true) > cfg.setPeerClassLoadingEnabled(true) > > val ignite: Ignite = Ignition.start(cfg) > Ignition.ignite().cache("test") > //LOG.info(">>> cache acquired") > > > } > > } > > > On Wed, Oct 16, 2019 at 3:41 PM sri hari kali charan Tummala < > kali.tumm...@gmail.com> wrote: > >> Hi All, >> >> I was able to create a working ignite cluster ( >> https://www.gridgain.com/docs/8.7.6//installation-guide/manual-install-on-ec2) >> on AWS I opened all the ports in my security group but when I try to >> connect ignite cluster from my Local PC Scala Code ignite fails with below >> error. >> >> I am using example-default.xml file >> >> <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>3.86.250.240:47100..47200</value> >> <value>3.84.154.193:47100..47200</value> >> <value>127.0.0.1:47100..47200</value> >> </list> >> </property> >> </bean> >> </property> >> </bean> >> </property> >> >> >> *Failed to connect to any address from IP finder (make sure IP finder >> addresses are correct and firewalls are disabled on all host machines)* >> >> *Error on Ignite Ec2 instance:-* >> >> class org.apache.ignite.internal.util.nio.GridNioException: Invalid >> message type: -4692 >> >> at >> org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.processSelectedKeysOptimized(GridNioServer.java:2437) >> >> at >> org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.bodyInternal(GridNioServer.java:2178) >> >> at >> org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.body(GridNioServer.java:1819) >> >> at >> org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:119) >> >> at java.lang.Thread.run(Thread.java:748) >> >> Caused by: class org.apache.ignite.IgniteException: Invalid message type: >> -4692 >> >> at >> org.apache.ignite.internal.managers.communication.GridIoMessageFactory.create(GridIoMessageFactory.java:1151) >> >> at >> org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$6.create(TcpCommunicationSpi.java:2336) >> >> at >> org.apache.ignite.internal.util.nio.GridDirectParser.decode(GridDirectParser.java:80) >> >> at >> org.apache.ignite.internal.util.nio.GridNioCodecFilter.onMessageReceived(GridNioCodecFilter.java:113) >> >> at >> org.apache.ignite.internal.util.nio.GridNioFilterAdapter.proceedMessageReceived(GridNioFilterAdapter.java:108) >> >> at >> org.apache.ignite.internal.util.nio.GridConnectionBytesVerifyFilter.onMessageReceived(GridConnectionBytesVerifyFilter.java:132) >> >> at >> org.apache.ignite.internal.util.nio.GridNioFilterAdapter.proceedMessageReceived(GridNioFilterAdapter.java:108) >> >> at >> org.apache.ignite.internal.util.nio.GridNioServer$HeadFilter.onMessageReceived(GridNioServer.java:3575) >> >> at >> org.apache.ignite.internal.util.nio.GridNioFilterChain.onMessageReceived(GridNioFilterChain.java:174) >> >> at >> org.apache.ignite.internal.util.nio.GridNioServer$DirectNioClientWorker.processRead(GridNioServer.java:1312) >> >> at >> org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.processSelectedKeysOptimized(GridNioServer.java:2411 >> >> >> -- >> Thanks & Regards >> Sri Tummala >> >> > > -- > Thanks & Regards > Sri Tummala > > -- Thanks & Regards Sri Tummala
