Hi,Looks like you are trying to connect to the wrong port. The default port for client connection is 10800.
Change:val cfg2 = new ClientConfiguration().setAddresses("100.25.173.220:47100..47700")
to
val cfg2 = new ClientConfiguration().setAddresses("100.25.173.220:10800")
-Artem
On 17.10.2019 03:39, alexanderko...@gmail.com wrote:
You need to replace the ip finder on all nodes to use the s3 one.add the libraries from |libs/optional/ignite-aws| to your application's classpath.No file is required. *From:* sri hari kali charan Tummala <kali.tumm...@gmail.com> *Sent:* Wednesday, October 16, 2019 8:10 PM *To:* user@ignite.apache.org; alexanderko...@gmail.com *Subject:* Re: Connection Refused in Scala Ignite Client (Help!) I this below property is while launching ignite on awsI already have ignite cluster running I just need to connect using java or Scala code which is failing with connection refused error.https://apacheignite-mix.readme.io/docs/amazon-aws#section-amazon-s3-based-discoveryOn Wednesday, October 16, 2019, sri hari kali charan Tummala <kali.tumm...@gmail.com <mailto:kali.tumm...@gmail.com>> wrote:Do I need to keep any file inside the s3 bucket or is it just a empty bucket ? With aws credentials and bucket name ? On Wednesday, October 16, 2019, <alexanderko...@gmail.com <mailto:alexanderko...@gmail.com>> wrote: Hi, Try using the S3 IP Finder: https://apacheignite-mix.readme.io/docs/amazon-aws#section-amazon-s3-based-discovery <propertyname="discoverySpi"> <beanclass="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi"> <propertyname="ipFinder"> <beanclass="org.apache.ignite.spi.discovery.tcp.ipfinder.s3.TcpDiscoveryS3IpFinder"> <propertyname="awsCredentials"ref="aws.creds"/> <propertyname="bucketName"value="YOUR_BUCKET_NAME"/> </bean> </property> </bean> </property> Thanks, Alex *From:* sri hari kali charan Tummala <kali.tumm...@gmail.com <mailto:kali.tumm...@gmail.com>> *Sent:* Wednesday, October 16, 2019 5:55 PM *To:* user@ignite.apache.org <mailto:user@ignite.apache.org> *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.i*gnite.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 <http://java.net>.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) at java.net <http://java.net>.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) at java.net <http://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 <http://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-- Thanks & RegardsSri Tummala -- Thanks & Regards Sri Tummala
