Hi,
Try using the S3 IP Finder:
https://apacheignite-mix.readme.io/docs/amazon-aws#section-amazon-s3-based-discovery
<property name="discoverySpi">
<bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
<property name="ipFinder">
<bean
class="org.apache.ignite.spi.discovery.tcp.ipfinder.s3.TcpDiscoveryS3IpFinder">
<property name="awsCredentials" ref="aws.creds"/>
<property name="bucketName" value="YOUR_BUCKET_NAME"/>
</bean>
</property>
</bean>
</property>
Thanks, Alex
From: sri hari kali charan Tummala <[email protected]>
Sent: Wednesday, October 16, 2019 5:55 PM
To: [email protected]
Subject: Connection Refused in Scala Ignite Client (Help!)
Hi All,
I am trying to connect my ignite cluster which is created on AWS (), now I am
suing scala code to connect to the client which is failing with connection
refused error.
In my security group I opened all the ports still I am having issues can anyone
help.
Error:-
Exception in thread "main" org.apache.ignite.client.ClientConnectionException:
Ignite cluster is unavailable
at
org.apache.ignite.internal.client.thin.TcpClientChannel.<init>(TcpClientChannel.java:114)
at
org.apache.ignite.internal.client.thin.TcpIgniteClient.lambda$new$0(TcpIgniteClient.java:79)
at
org.apache.ignite.internal.client.thin.ReliableChannel.<init>(ReliableChannel.java:84)
at
org.apache.ignite.internal.client.thin.TcpIgniteClient.<init>(TcpIgniteClient.java:86)
at
org.apache.ignite.internal.client.thin.TcpIgniteClient.start(TcpIgniteClient.java:205)
at org.apache.ignite.Ignition.startClient(Ignition.java:586)
at
com.ignite.examples.igniteStartup.IgniteClientConnection$.main(IgniteClientConnection.scala:36)
at
com.ignite.examples.igniteStartup.IgniteClientConnection.main(IgniteClientConnection.scala)
Caused by: java.net.ConnectException: Connection refused (Connection refused)
at java.net.PlainSocketImpl.socketConnect(Native Method)
at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
at
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at java.net.Socket.connect(Socket.java:538)
at java.net.Socket.<init>(Socket.java:434)
at java.net.Socket.<init>(Socket.java:211)
at
org.apache.ignite.internal.client.thin.TcpClientChannel.createSocket(TcpClientChannel.java:216)
at
org.apache.ignite.internal.client.thin.TcpClientChannel.<init>(TcpClientChannel.java:108)
... 7 more
Scala Code:-
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.{ClientConfiguration,
IgniteConfiguration}
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 com.ignite.examples.model.Address
import org.apache.ignite.client.{ClientCache, IgniteClient}
import scala.collection.JavaConversions._
object IgniteClientConnection {
def main(args: Array[String]): Unit = {
System.out.println()
System.out.println(">>> Thin client put-get example started.")
System.out.println(">>> I am here.")
val cfg2 = new
ClientConfiguration().setAddresses("100.25.173.220:47100..47700")
val igniteClient:IgniteClient = Ignition.startClient(cfg2)
val CACHE_NAME = "put-get-example";
//val cache:ClientCache[Integer, Address] =
igniteClient.getOrCreateCache(CACHE_NAME)
System.out.format(">>> Created cache [%s].\n", CACHE_NAME)
}
}
--
Thanks & Regards
Sri Tummala
