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. > 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 > unavailableat 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.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 > > > -- Thanks & Regards Sri Tummala
