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 <
[email protected]> 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
