I this below property is while launching ignite on aws I 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-discovery On Wednesday, October 16, 2019, sri hari kali charan Tummala < [email protected]> 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, <[email protected]> wrote: > >> Hi, >> >> Try using the S3 IP Finder: https://apacheignite-mix.readm >> e.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.d >> iscovery.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 >> unavailableat org.apache.i*gnite.internal.cli >> ent.thin.TcpClientChannel.<init>(TcpClientChannel.java:114) >> at org.apache.ignite.internal.client.thin.TcpIgniteClient.lambd >> a$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(AbstractPlainSock >> etImpl.java:350) >> at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPl >> ainSocketImpl.java:206) >> at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocket >> Impl.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.crea >> teSocket(TcpClientChannel.java:216) >> at org.apache.ignite.internal.client.thin.TcpClientChannel.<ini >> t>(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 >> >> >> > > > -- > Thanks & Regards > Sri Tummala > > > -- Thanks & Regards Sri Tummala
