RE: Connection Refused in Scala Ignite Client (Help!)

[alexanderkor12]

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 <kali.tumm...@gmail.com> 
Sent: Wednesday, October 16, 2019 5:55 PM
To: 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.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